HTTPS リスナーによるイベント処理

HTTPS リスナーはイベントをストリームに書き込みます。このストリームは、Data Connection でリスナーの概要ページに移動すると確認できます。データがストリームに格納されると、いくつかの処理オプションが利用可能になります。

Automate によるストリーム処理

ストリームは Automate で直接処理でき、受信イベントごとにアクションまたは関数を実行できます。オントロジー内にオブジェクトを作成したり、AIP ロジックを実行したり、関数内でソースを使用して、イベントを送信したシステムにデータを書き戻すなど、外部システムとやり取りしたりできます。

Automate によるストリーミングイベントの処理は、次の場合に適しています。

• イベントストリームのスループットが高くない
• イベント処理がステートレスである
• 数秒の遅延が許容される
• 少なくとも1回の処理で十分である

このアプローチは、ほとんどのリスナー統合に適しており、低コストで保守の手間が少ないイベント処理ワークフローを提供します。

Automate によるリスナーイベントの処理について、リスナーを使用して AI 搭載チャットボットを作成するガイドで詳しくはこちらをご覧ください。

ストリーミングパイプライン

リスナーのイベントストリームは、より低遅延な代替手段としてストリーミングパイプラインで処理できます。これらのパイプラインは、高スループットのストリーム、ステートフルなイベント処理、および（オプションで）厳密に1回のイベント処理をサポートします。また、ストリーミングパイプラインでは UDF を活用して、強力なリアルタイムイベント処理ワークフローを構築できます。

バッチパイプライン

リスナーのイベントストリームは、数分ごとに元データセットにアーカイブされます。このデータセットは、プラットフォーム内のほかのデータセットと同様に使用でき、データパイプラインを構築したり、オントロジーの元データとして使用したりできます。

履歴分析が必要なユースケースや、リアルタイムではないユースケースには、バッチパイプラインを使用する必要があります。