通用JSON 告警模块
MySQL 告警统计
全量保存到 RuleService
JsonAlertJobDriver
配置解析
Rule
获取MySQL中的规则数据源
AlertManager 告警
CLOUD_EVENT
flattenAsMap
Driver
车机端埋点日志
isValid
背景描述：动态修改规则，实时筛选出满足规则的JSON Kafka数据源业务逻辑路模块：1、通过命令行参数控制由<通用JSON 告警模块>或者<Sentry 异常崩溃业务处理模块>处理数据流2、通过--app.type 选择每种业务逻辑的配置参数，包括kafka topic 配置、mysql sink 输出的字段的配置、AlertManager 告警内容的配置规则匹配模块由 RulesService 实现，包含的功能有：1、全量规则数据的同步（适用于自定义的SourceFunction）2、增量规则数据的同步（适用于CDC捕获binlog 场景）3、binLog 转换成Rule对象（适用于CDC捕获binlog 场景）span style=\"font-size: inherit;\
规则表达式
CLIENT_EVENT
是否匹配
Sentry 异常上报
获取Kafka中的Sentry events 数据源
JSON
CLOUD_LOGNT
RuleService matchRules
Avaitor 表达式引擎
Sentry 异常崩溃业务处理模块
云端埋点日志
云端微服务日志
获取Kafka中的 JSON 数据源
--app.type
Flink 流式处理主流程图
RuleService matchRules模块
SentryAlertJobDriver
SENTRY
业务逻辑路由模块
Kafka 实时监控
Sentry 上报异常数据处理逻辑
Flink job name
