Wso2 CEP中的执行计划模板

Question

我正在使用Kafka CEP来处理来自WSO2主题的事件。我想将其推广到多个kafka主题，它们以类似的格式存储日志，即每个主题的每个分区存储特定人的数据。

场景如下；一个主题表示一个超级组，其中每个分区都是该组中的一个人。在每个分区中，存在该人的JSON格式数据点{银行交易信息(交易时间、贷方/借方、金额)等}。

我希望能够以这样的方式打破数据，最终我得到由个人贷记/借记的金额流，即在第一个(级别)执行计划之后，不同的人数据被分解为单独的数据流，紧随其后的是第二个(级别)执行计划，它进一步将每个流分为(时间戳，贷方/借方)流和(时间戳，金额)流。

实现这一点的简单方法是编写一个程序，它以编程方式为您写出执行计划(siddhisql文件)、事件流(JSON文件)、事件接收器和发布器(XML文件)。但是，随着主题数量的增加，这些文件的数量也会增加。

有没有什么模板方法可以做到这一点(至少创建执行计划)？

Answer 1

您可以创建执行模板，您可以在其中定义执行计划模板，并且可以包括模板所需的流。定义模板时，您可以定义参数，稍后可以使用实际值配置这些参数。在当前发布的版本中，CEP不支持包含模板的接收者和发布者。

请参阅Creating Execution Templates的WSO2文档。要了解有关模板结构的更多信息，请参阅this blog post。