flume系列之：查询多个flume agent组是否有topic重复接入情况
flume系列之：查询多个flume agent组是否有topic重复接入情况
- 一、查询zk节点下的flume agent组
- 二、获取采集的topic
- 三、获取重复接入的topic，支持设置重复接入白名单
- 四、执行流程
- 五、完整代码
一、查询zk节点下的flume agent组
def get_flumeAgent_zkPath(zkRootPaths):for zkRootPath in zkRootPaths:# 腾讯云prodallFlumeAgent = zk.get_children(zkRootPath)for flumeAgent in allFlumeAgent:flumeAgentPath = zkRootPath