如何删除当前节点上的所有已经定义的流计算引擎?

我在测试DolphinDB的流计算功能时,定义了很多流计算的引擎,有没有办法一键删除当前节点上的所有流计算引擎?

请先 登录 后评论

1 个回答

Jason Tang - 时序数据库技术支持

可以参考下面的自定义函数,作用是删除当前节点上的所有流计算引擎:

def DropAllEngines(){
	if(getStreamEngineStat().rows() > 0){
		engineTypes = getStreamEngineStat().keys()
		for(engineType in engineTypes){
			engineNum = size(getStreamEngineStat()[engineType])
			i = 0
			do{	
				print("Drop Stream Engine: " + getStreamEngineStat()[engineType].name[0])
				i = i +1
				try{
				dropStreamEngine(getStreamEngineStat()[engineType].name[0])
				}
				catch(ex){
					print(ex)
				}
			}
			while(i < engineNum)
		}
	}
	print("All engines have been dropped !")
}
请先 登录 后评论