WSO2 CEPの実行計画テンプレート

Question

私は、カフカのトピックからのイベントを処理するためにWSO2 CEPを使用しています。私はこれを一般的なものにして、複数のカフカのトピックにログを保存します。これらのトピックは、同様の形式、つまり各トピックの各パーティションに特定の人物のデータを格納します。

シナリオは次のとおりです。トピックは、各パーティションがそのグループ内の人であるスーパーグループを示します。各パーティションには、その人のJSON形式のデータポイント{銀行取引情報（取引時刻、クレジット/デビット、金額）}などがあります。

私は最終的に、人のクレジット/デビットされた金額のストリームを得るようにデータを分割することができるようにしたいと思います。各ストリームを（タイムスタンプ、クレジット/デビット）ストリームと（タイムスタンプ、量）ストリームにさらに分割する実行計画の第2（レベル）で実行する。

実行計画（siddhisqlファイル）、イベントストリーム（JSONファイル）、イベント受信者、およびパブリッシャー（XMLファイル）をプログラマチックに書き出すプログラムを作成するのは難しい方法です。しかし、トピックの数が増えると、これらのファイルの数が増えます。

これを実行するためのテンプレート方法はありますか（少なくとも実行計画を作成する）？

Answer 1

実行計画テンプレートを作成して、実行計画テンプレートを定義し、テンプレートに必要なストリームを含めることができます。テンプレートを定義するときに、実際の値で後で設定できるパラメータを定義することができます。現在リリースされているCEPでは、テンプレートの受信者と発行者を含めることはサポートされていません。

WSO2のドキュメントn Creating Execution Templatesを参照してください。テンプレート構造の詳細については、this blog postを参照してください。