-
storm实时处理报名签到数计算
资源介绍
报名签到数计算
ActivitySignParseBolt
1、过滤异常数据(INSERT、有效、当天)
2、解析出字段
3、发射Tuple
ActivitySignSpout
1、读取MQ中数据
2、发射Tuple
ActivitySignSum2RedisBolt
1、从Redis中读取今日报名签到数
2、计算总的报名签到数
3、写入redis
ActivitySignSumBolt
1、从Redis中读取今日报名签到数
2、计算报名签到数
3、设定TickTuple,每分钟往下游发射一次Tuple
ActivitySignToMysqlBolt
1、解析Tuple
2、写入Mysql
Redis
MySQL
MQ