有
删除消息
结束
开始推送
是否有订阅
是否重复消息
SQS
重复
push binary log
获取推送事件（push_pending）
push data
mysql
否
存储消息（events）
失败
sub-data（canal）
删除webhook
SNS Topic
没有
邮件告警
是
判断推送次数
协程池消费消息
是否推送成功
获取hooks(hooks)
存储推送事件（push_pending）
定时从SQS拉取10条数据
SQS来源示意图
存储推送内容（event_content_products）
for循环
消息
SQS消费示意图
