概述
本文通过经典电商案例，帮助您了解实时计算流式作业开发流程。
实时电商案例介绍
实时销量销量作为电商营销的重要环节，受到越来越多的关注。为了保证在同时满足数据的正确性和实效性的前提下，在流式的数据里做实时销量监控。实时计算通过消费Kafka中数据源表接入的数据，实时计算销售数据源中销售总额，并写入至结果表中进行存储，方便第三方系统进行调用。
业务架构图
- MySQL数据源表
| 字段名 | 类型 | 注释 |
|---|---|---|
| event_id | int | 数据库自增id，主键 |
| id | varchar | 商品id |
| buyer_id | varchar | 消费者id |
| goods_type | varchar | 商品类型 |
| pay_time | timestamp | 支付时间 |
| buy_amount | double | 购买金额 |
| buy_way | varchar | 购买渠道 |
- MySQL结果表
| 字段名 | 类型 | 注释 |
|---|---|---|
| totalsale | double | 销售金额总计 |