Apache用の動的ストリームSQL Flink CEP

Question

CEP用Flinkで消費されるストリームSQLをKafkaに入れたいと思います。これは良い方法ですか？

私は動的パターン定義がFlinkでは許可されていないことを知っており、無制限のイベントストリームで変更できるルールを適用する必要があります。

例を挙げてください。

ユーザーがデバイスのルールを定義するためのUIがあります。 AWS IoTハブのようなサービスをシャドウイングして物理デバイスの状態を維持していることを想像してみましょう。また、すべてのデバイスの特定のルールをシャドールールに入れ、シャドーアクターがセンサーデータを受信したときに、それは、ルールエンジン（kafka経由）としてFlinkによって消費されるようにルールが追加されたデータを放出することができます。だから私はFlinkに、私の入ってくるセンサーデータ（そのルール付き）をすべてのデバイスで違うものにすることを望みます。

Answer 1

私はあなたの質問から理解したことは、異なるルールで異なるストリームを処理したいということです。その場合は、これらのデバイスからKafkaのトピックにストリームを送信する必要があります。その後、Flinkで複数のCEPインスタンスを起動します。

StreamExecutionEnvironment envrionment1 = StreamExecutionEnvironment.createLocalEnvironment(1); 
... 
StreamExecutionEnvironment envrionmentn = StreamExecutionEnvironment.createLocalEnvironment(1); 

各インスタンスはカフカトピック（それぞれ1つのデバイスを表す）に加入し、各FLINK例において差分パターンを追加すべきです。