华为云首页用户手册

MAPREDUCE服务 MRS-Spark Structured Streaming对接Kafka样例程序开发思路:场景说明

MAPREDUCE服务 MRS-Spark Structured Streaming对接Kafka样例程序开发思路:场景说明

时间：2024-06-29 14:11:27

MAPREDUCE服务 MRS Spark Structured Streaming对接Kafka样例程序

场景说明

假定一个广告业务，存在广告请求事件、广告展示事件、广告点击事件，广告主需要实时统计有效的广告展示和广告点击数据。

已知：

终端用户每次请求一个广告后，会生成广告请求事件，保存到kafka的adRequest topic中。
请求一个广告后，可能用于多次展示，每次展示，会生成广告展示事件，保存到kafka的adShow topic中。
每个广告展示，可能会产生多次点击，每次点击，会生成广告点击事件，保存到kafka的adClick topic中。
广告有效展示的定义如下：
1. 请求到展示的时长超过A分钟算无效展示。
2. A分钟内多次展示，每次展示事件为有效展示。
广告有效点击的定义如下：
1. 展示到点击时长超过B分钟算无效点击。
2. B分钟内多次点击，仅首次点击事件为有效点击。

基于此业务场景，模拟简单的数据结构如下：

广告请求事件
 数据结构：adID^reqTime
广告展示事件
 数据结构：adID^showID^showTime
广告点击事件
 数据结构：adID^showID^clickTime

数据关联关系如下：

广告请求事件与广告展示事件通过adID关联。
广告展示事件与广告点击事件通过adID+showID关联。

数据要求：

数据从产生到到达流处理引擎的延迟时间不超过2小时
广告请求事件、广告展示事件、广告点击事件到达流处理引擎的时间不能保证有序和时间对齐

上一篇：MAPREDUCE服务 MRS-Spark Structured Streaming对接Kafka样例程序开发思路:数据规划

下一篇：MAPREDUCE服务 MRS-操作Avro格式数据:提交命令

新客秒杀 2核2G 3M L实例

68元/年

普惠上云领千元上云礼券

立即前往

企业专享 X实例 4核8G 5M

888元/年

热门域名 1元随心购

1元/年起

MAPREDUCE服务 MRS-Spark Structured Streaming对接Kafka样例程序开发思路:场景说明

意见反馈

0/200

提交成功！非常感谢您的反馈，我们会继续努力做到更好反馈提交失败！请稍后重试！

推荐文章

解决方案
相关专题