[社区]基于Flink+Drools可自定义规则的实时告警系统

目前常见的大数据告警系统更多是基于SparkStreaming+Drools,其实时性是基于微批实现时延相对较高,不支持广播流告警规则的更新只能依赖于广播变量定时更新,且不支持状态计算将不得不引入外部存储如Redis因此降低了系统的吞吐量同时也增大了系统的复杂度。新一代的分布式处理引擎Flink是基于事件驱动且可进行状态计算,大大提高了数据处理能力和简化了平台的复杂度。

基于Kafka->Flink+Drools支持动态规则的设备实时告警系统

基于Flink+Drools可自定义规则的实时告警系统车联网大数据游戏大数据智能制造大数据新零售大数据物流大数据金融大数据FlinkDrools
头像数智先锋   创建 于 2024年03月30日 阅读次数 64
精彩评论
评论
全部评论