ストリーミング

リアルタイムのデータ処理のユースケースでは、ストリーミングデータセットまたはオブジェクトに対して自動化を設定することを検討してください。新しいデータがオントロジーに入ってから数秒以内に効果が実行されます。

ストリームを元データとするオブジェクトに対する自動化

より大規模な処理が必要な場合は、ストリームを元データとするオブジェクトに対して自動化を設定することで、スループットの制限なく監視できます。これは、金融取引の監視や大規模な IoT の導入など、データが継続的に取り込まれ、処理される大規模なアプリケーションで特に役立ちます。

これを設定するには、オブジェクトが変更される条件に移動し、ストリームを元データとするオブジェクトを選択します。条件の下に表示される評価頻度が、それに応じて更新されます。

リアルタイムのストリーム監視では、監視するプロパティを明示的に指定することはできません。すべての変更が処理されます。状態を保持する実行に対応するには、監視するオブジェクトセットを変更し、下流のオントロジーで状態を扱います。

ユースケースの例

不正検知のために取引を監視する必要がある金融機関を想定してください。ストリームを元データとするオブジェクトを使用すると、処理する取引量にかかわらず、不審なパターンの検出をリアルタイムで自動化できます。

ストリーミングデータセットに対する自動化

Automate を通じてストリーミングデータセットを直接監視できます。スループットが1秒あたり200件を超えない場合、データストリームに対してリアルタイムの自動化を実行できます。この機能は、ライブのセンサーデータの監視やリアルタイムのユーザーインタラクションの追跡など、入ってくるデータに基づいて即座に対応する必要があるシナリオに最適です。

この条件を設定するには、ストリーム条件を選択し、ユーザーインターフェースで該当するストリーミングデータセットを検索します。次に、アクションやロジックなどの効果の設定に進みます。

バイナリストリームの列を効果の入力として使用すると、Automate がその内容をデコードします。たとえば、バイナリストリームの値 eyJIZWxsbyI6ICJXb3JsZCEifQ== は、文字列値 {"Hello": "World!"} として効果に渡されます。

効果の実行をキューに入れることで、自動化イベントをトリガーされた順序で逐次処理できます。キューは、イベントを順番に実行する必要がある場合や、同時実行数の制御、容量制限の管理、競合の回避が必要な場合に役立ちます。

ユースケースの例

温度センサーデータのストリームを監視するシナリオを考えてみましょう。温度が特定のしきい値を超えた場合にアラートを発する自動化を設定すると、過熱の可能性がある問題に即座に対応できます。

ストリーミング時系列条件

ストリーミングデータを使用して、時系列条件を低遅延で評価します。設定の詳細については、ストリーミングアラートを参照してください。