既定のイベントストリームと派生イベントストリームを作成する
この記事では、既定の Fabric イベント ストリームと派生 Fabric イベント ストリームを作成する方法について説明します。 データ ストリームは、迅速なアクションと分析のためのさまざまな機能を提供する、動的で継続的なデータ フローです。 データ ストリームを使用すると、リアルタイム アラートを設定し、さまざまな種類のデータ ストアにフィードし、複数の顧客がサブスクライブできる発行/サブスクライブ モデルを有効にすることができます。
ファブリック イベント ストリーム内のリアルタイム ハブ機能の統合により、これらの機能がさらに強化されます。 この統合により、さまざまな処理操作を使用して複数のデータ ストリームを作成および管理できます。これにより、リアルタイム ハブに表示できます。
概念
イベントストリーム は、Fabric ワークスペース内の項目であり、Fabric のさまざまな宛先にデータ ストリームを取り込み、変換し、ルーティングできます。
ストリームは、データ イベントの継続的かつ無制限のフローです。 データ イベントが Fabric イベント ストリームに流れ込むと、データ イベントを表すために Fabric イベント ストリーム内にストリームが形成されます。 Fabric イベント ストリームには、次の 2 種類のストリームがあります。
既定のストリーム。 すべての Fabric イベント ストリーム項目には、ストリーミング ソースがイベントストリームに追加されると自動的に生成される既定のストリームが付属しています。 これは、ストリーミング ソースから送信される生のイベントを表します。 Fabric では、既定のストリームを変換して複数の宛先にルーティングできます。 既定のストリームは、リアルタイム ハブから表示できます。
派生ストリームは、フィルターやフィールドの管理などの一連のストリーム操作を追加した後に作成される、Fabric イベント ストリーム内の特殊な種類の宛先です。 派生ストリームは、ストリーム処理の後に変換された既定のストリームを表します。 派生ストリームのストリーミング データをファブリックの複数の宛先にルーティングすることもできます。 作成されると、リアルタイム ハブを介して組織内の他のユーザーによる追加の使用または分析を行う準備が整います。
既定のストリームを作成する
新しいイベントストリームを作成すると、イベントストリームにソースを追加でき、既定のストリームが自動的に生成されます。 次の例は、Fabric イベント ストリーム項目に自転車サンプル データ ソースを追加すると、既定のストリーム es-5-stream が自動的に生成されることを示しています。
派生ストリームを作成する
新しい派生ストリームを作成するには、[フィルター] などの操作をイベントストリームに追加します。 次に、[ストリーム]オプションを選択します。
新しいストリームに名前を付け、[発行]を選択して変更をコミットします。
完了したら、ストリームのプレビューやストリームのフロー先の追加など、リアルタイム ハブの既定のストリームと派生ストリームの両方にアクセスして、さらに使用できます。
