dispatcher
2021-04-26 10:53:09 12 举报wwww
作者其他创作
大纲/内容
文件信息
阿里云文件列表获取偏移量
重启
是
是否cronworkflow
worker
否
匹配得到本机处理历史文件信息
分配任务到worker
redis
kafka
得到wokflow阿里云日文件信息
开groutine 执行 for{增量获取此job产生的oss文件开groutine并分配读取任务到worker如果5天不产生新文件 break}
收藏
0 条评论
下一页
