如何快速查找所有的高可用流数据表?

在一个DolphinDB节点上定义了高可用流数据表,如何快速查到当前节点上所有已经定义的高可用流数据表呢?

请先 登录 后评论

1 个回答

Yating Xie

streamingHADir:流数据Raft日志文件的存储目录。

遍历streamingHADir目录可以得到所有的高可用流表的表名,以下脚本中,所有的高可用流表表名存储在数组haStreamTableNameList中。

haStreamTableNameList = array(STRING)
if(getConfigure("streamingHADir")!=NULL){
	for (i in files(getConfigure("streamingHADir")).filename){
		haStreamTableNameList.join!(strReplace(files(getConfigure("streamingHADir") + "/"+ i + "/persistReg").filename, ".save", ""))
	}
	print(haStreamTableNameList)
}else print("!没有配置streamingHADir路径!")
请先 登录 后评论