Flink框架设计

DataStream Process

Kafka ProtoBuf 消息解压缩及反序列化

match

飞书或短信实时告警

告警规则管理后台

real-timematch trigger

规则M 计算

DataStream Filter

Calculator 1实时计算并存入Redis

real-time trigger

工单binlog日志

运行时动态加载算子

定义规则与算子关系

规则1 计算

三方系统

规则引擎

Calculator N实时计算并存入Redis

实时预警系统

Calculator 2实时计算并存入Redis

Flink streaming DataSource