概述

本文通过经典电商案例,帮助您了解实时计算流式作业开发流程。

实时电商案例介绍

实时销量销量作为电商营销的重要环节,受到越来越多的关注。为了保证在同时满足数据的正确性和实效性的前提下,在流式的数据里做实时销量监控。实时计算通过消费Kafka中数据源表接入的数据,实时计算销售数据源中销售总额,并写入至结果表中进行存储,方便第三方系统进行调用。

业务架构图

快速开始-架构图.jpg
  • 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

销售金额总计

pay_time

timestamp

支付时间