Flink 实时规则告警系统

通用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