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