实时点击storm拓扑结构图
2016-10-18 17:41:54 0 举报
在实时点击Storm拓扑结构图后,我们可以看到一个高度可视化的流程图。图中展示了各个组件之间的连接关系和数据传输路径。首先,数据源作为输入被引入系统,然后通过Spouts(数据发射器)进行数据的分发。接下来,数据经过Bolts(数据处理单元)进行处理和转换,最终得到所需的结果。在这个过程中,数据流可能会经过多个Bolts进行处理,每个Bolt都可以对数据进行特定的操作。此外,拓扑结构图中还包含了一些控制节点,如Stream Grouping、并发度控制等,用于优化系统的运行效率。总之,实时点击Storm拓扑结构图可以帮助我们更好地理解整个数据处理过程,从而为系统的优化和调试提供有力的支持。
作者其他创作
大纲/内容
Filter切分消息体,获取字段Blot
ack_action
客户端(点赞、评论等行为时,发送相应的ack请求回商业化)
engine
go_mario ad_info 广告接口
服务端
客户端评论、点赞、收藏等广告视频流量请求
开屏联动的aid
开屏SDK
客户端
item 信息pack
go_mario 广告信息
engine跟进固定请求的aid下发广告
抖音信息流广告请求
sati
广告item_id
Recorder录入数据库Blot
并行请求
feed请求带展示的aid回来
\"host\": \"myaddata.db\
go_mario 打包相关的feed广告数据
天池(同步筛选的cid是否还在投)
SimpleSpout(从kafka中获取实时数据,包括请求、点击、曝光,按照topic运行Topology)
Counter 按key统计Blot
redis存储(cid + log_extra)初期缓存3天
交互沟通是否展示联动开屏开屏样式由客户端fake
go_mario_api(解析客户端ack数据 uid + item 为key缓存数据)
0 条评论
下一页