-
实时处理新增会员数计算-storm
资源介绍
新增会员数计算
NewMemberParseBolt
1、过滤异常数据（INSERT、当天）
2、解析出字段
3、发射Tuple
NewMemberSpout
1、读取MQ中数据
2、发射Tuple
NewMemberSum2RedisBolt
1、从Redis中读取今日新增会员数
2、计算总的新增会员数
3、写入redis
NewMemberSumBolt
1、从Redis中读取今日新增会员数
2、计算新增会员数
3、设定TickTuple，每分钟往下游发射一次Tuple
NewMemberDetail2MQBolt
1、解析消息
2、写入MQ
NewMemberToMysqlBolt
1、解析Tuple
2、写入Mysql
Redis
MySQL
MQ
MQ
- 上一篇: 线下订单计算-storm实时处理
- 下一篇: 报名签到数计算-storm实时处理