听云和MongoDB数据对接流程图
2022-02-17 08:52:41 0 举报听云和MongoDB数据对接流程图
作者其他创作
大纲/内容
客户 MongoDB
调用听云平台的API，获取数据
将格式化后的数据推送到kafka中，topic和MongoDB使用同一个，用SOURCE字段表示数据来源，值为2，表示来自听云平台
向听云平台用户认证服务发起认证请求
不存在
DataBank等服务从kafka指定队列中获取消息
从听云平台申请一个新的token
用户主动调用我们写的脚手架的接口，手动调用听云平台获取数据
没有token或者token过期
从配置文件中获取听云接口
格式化消息参数，使其成为我们需要的格式
项目启动时触发定时任务
验证通过并且token没有过期
第一次格式化数据，尽量让数据保证和MongoDB存入kafka的数据格式保持一致
存在
在CMDB上创建资源
判断CMDB中是否存在该资源
kafka接收MongoDB的消息队列，添加一个来SOURCE字段，值为1，表示数据来源为MongoDB
从kafka中获取消息
发送格式化以后的数据到新的kafka队列中
收藏
收藏
0 条评论
下一页
