请问Flinkcdc中有flink动态规则引擎方面的开源项目吗?
在 Flink CDC 中,目前没有专门的开源项目提供动态规则引擎功能。但是,您可以使用 Flink 的流处理引擎和 Flink CEP 库来实现动态规则引擎的功能。
Flink 是一个高性能、分布式、流处理引擎,可以处理大规模的实时数据流。Flink CEP 库是 Flink 的一个扩展库,提供了基于事件流的复杂事件处理功能,可以用于实现动态规则引擎。
具体来说,您可以将 Flink CDC 中的数据作为事件流输入到 Flink CEP 库中,然后使用 Flink CEP 库提供的模式匹配和规则引擎功能,根据实时数据流的特征和规则,进行实时的数据分析和处理。Flink CEP 库支持基于时间窗口、事件数量窗口、追溯窗口等多种窗口类型,可以支持各种类型的动态规则引擎应用场景。
需要注意的是,使用 Flink CEP 库需要对 Flink 的编程模型和 API 有一定的了解。
issue 200,可以参考下,然后代码里面涉及的实体类,参考阿里的规则文档,和github有个vvr阿里的。参考一下这个文章。此回答整理至钉群“Flink CDC 社区”。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。