Apache Flink在蔚来汽车如何应用？

1 .实时看板。主要分为三层。第一层是数据层即 Kafka 的实时数仓，通过 Flink 对这些数据进行处理后将它们实时地推到后台，后台再实时地把它们推到前端。后台与前端的交互是通过 web socket 来 实现的，这样就可以做到所有的数据都是实时推送。

1. CDP（Customer Data Platform）CDP 是一个运营平台，负责偏后台的工作。蔚来汽车的 CDP 需要存储一些数据，比如属性的数据存在 ES 里、行为的明细数据包括统计数据存在 Doris 里、任务执行情况存在 TiDB。其中主要有两个实时场景的应用：第 一个是属性需要实时更新，否则可能造成运营效果不佳；第二个是行为的聚合数据有时候也需要实时更新。

2. 实时数仓。整体上与离线数仓非常相似，也是有ODS层、DWD 层、DWS 层和 Application 层。不同之处在于它有一个维度层 (DIM 层)，里面有很多不同的存储介质，维度信息可以放在TiDB，并通过 AIO 的方式访问维度表；也可以放在 Hive，用 Temporal Join 的方式去进行关联；有一些数据是一直在变化的，或者需要做一些基于时间的关联，可以把数据放到 Kafka 里，然后用 Broadcast 或者 Temporal Join 去进行关联。

以上内容摘自《Apache Flink 案例集（2022版）》电子书，点击https://developer.aliyun.com/ebook/download/7718 可下载完整版