实时计算平台
实时计算平台 streaming 是一个数据事件分发中转平台,底层由两条分支技术体系组成,一条是 flink 数据流,另一条 Tdengine 数据订阅,它们各自独立,而且能同时一起运行对外提供服务。
- flink 数据流:flink 实时监听数据库 binlog 日志——》将监听到的数据流转发到 kafka 集群——》通过事件中心对接 kafka 把数据流转化为数据事件——》最终流转到用户的业务服务
- Tdengine 数据订阅:创建 Tdengine SQL 主题——》streaming 实时订阅监听 tdengine 主题——》将获取的数据事件推送给事件中心——》最终流转到用户的业务服务