信息流泳道图
2022-06-06 16:49:36 0 举报test
作者其他创作
大纲/内容
BetaasoapiTask
no
接收
nsq
生产者：xs.beta.aso.api.todb
yes
信息流进来
give_up
信息流数据处理_runApi_common
多协程序消费
banban_help（回调)
是否通用渠道
Goroutine
muid md5处理
批量发布nsq
chan
ES日志
信息流落盘saveDataToImei
banban_help（入库)
go mess(入口)
是否重复
信息流流程图
消费者：xs.beta.aso.api
push channel
banban_help(入口数据处理)
是否召回
BetaasonoticeTask
存redis 以oaid/muid/oip为维度
参数校验
信息流数据处理_asoApi
notice/main.go
imee_server(落表前数据处理)
批量落盘bms_aso_imei_commonxsst_aso_imei_common
生产者：aso.notice
消费者：xs.beta.aso.api.todb
BetaasoapiwritetodbTask
生产者：xs.beta.aso.api
参数组装
0 条评论
下一页
