Wso2 CEP 中的执行计划模板答案

【问题标题】：Execution plan templates in Wso2 CEPWso2 CEP 中的执行计划模板
【发布时间】：2016-06-30 14:35:19
【问题描述】：

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

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

我希望能够以这样一种方式分解数据，以便最终获得个人贷记/借记的金额流，即在第一个（级别）执行计划之后，不同的个人数据被分解为单独的数据流，然后第二（级别）执行计划，进一步将每个流分为（时间戳、贷记/借记）流和（时间戳、金额）流。

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

是否有任何模板方式可以做到这一点（至少创建执行计划）？

【问题讨论】：

【解决方案1】：

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

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

【讨论】：

感谢您的回答。但这不是我所期待的。是否可以使用占位符变量来选择接收和发布流？即我得到一个可用流的下拉列表，然后我选择我感兴趣的流？
技术上是可行的，但下拉内容会很复杂。在 Siddhi 查询模板中，您可以在定义流的位置放置带有 $ 的参数。可以为下拉列表值包含选项定义。这些值包含流及其参数。