「ビジネス」ユーザーが入力ストリームから取り込まれたデータのルールを作成および編集できるようにする必要があります。ルールはビジネスに適したものでなければならず、開発サイクルがあってはなりません。これが私が考えていることの例です：
"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 製品はありますか?
自作する必要がある場合、この問題で推奨される「ストリーム」設計パターンはありますか?