リアルタイムルール編集とKafkaStreams

Question

"ビジネス"ユーザが入力ストリームから取り込まれたデータに関するルールを作成し編集できるようにする必要があります。ルールはビジネスフレンドリーでなければならず、開発サイクルはありません。ここで私は考えています何の例です：気象ステーションと接続された車両のストリーミングデータとして

"if weatherStation.id == 100 and weatherStation.temp < 33 and detectedPctWipersOn = 90% 
then return true 
else return false" 

が摂取されるが、私はこのルールを適用する必要がありますが、ルールの変更は、detectedPctWipersOnは= 75％、ルールを避ける場合再展開や再起動なしにリアルタイムで適用する必要があります。データ駆動型である必要があります。

Siddhi CEP（WSO2 CEP）は、「デプロイ済み」ルールのみをサポートしているようです。 特に、KafkaStreamsでうまくいけば、私が必要とするものを実現できる他のCEP製品はありますか？

私がロール・マイ・オーナーでなければならない場合、この問題で推奨される「ストリーム」デザイン・パターンはありますか？

Answer 1

この要件では、Siddhiエンジンを使用する代わりに、CEP製品を使用してみてください。これにはquery templating facilityが付属しています。このテンプレートでは、設定するユーザーにパラメータのみを公開した、あらかじめ定義されたテンプレートを使用できます。例：WeatherStationTemperature。パラメータが変更されると、内部的にCEPによってクエリが再デプロイされ、変更がすぐに反映されます。

これは、例のようにフィルタのようなステートレスなクエリではうまく動作しますが、ウィンドウやパターンなどを使用すると状態が失われます。そのため、データベースバックアップのテーブル/ウィンドウを適切に実装する必要がありますユースケース。