Eventstream のソースと宛先
Eventstream を使用すると、単純に言えば、ソースからリアルタイム データがキャプチャされ、キャプチャされたデータが宛先に読み込まれます。
Eventstream ソース
Fabric リアルタイム ハブのイベント ソースには、特に以下のものを含めることができます。
- Azure Event Hub:Azure Event Hubs は、Azure イベント ハブからイベント データを取得できるようにするソースです。 Azure イベント ハブのデータ形式とコンシューマー グループを指定することができます。 適切な認証とプライバシー レベルを使用して、Azure イベント ハブへのクラウド接続を作成することもできます。
- Azure IoT Hub:何百万もの IoT 資産をノーコードのエクスペリエンスで接続、監視、管理するために利用する SaaS サービス。
- Azure SQL Database 変更データ キャプチャ (CDC):データベース内のデータの変更を識別および追跡し、リアルタイムまたはほぼリアルタイムのデータ移動を可能にするソフトウェア プロセス。
- PostgreSQL データベース CDC:Microsoft Fabric Eventstream 用の PostgreSQL データベース CDC (変更データ キャプチャ) コネクタを使用すると、PostgreSQL データベース内の現在のスナップショットがキャプチャされるとともに将来の変更が追跡され、このデータのリアルタイム処理と分析を Fabric 内で行うことができます。
- MySQL データベース CDC:Microsoft Fabric Eventstream 用の Azure MySQL Database CDC ソース コネクタを使用すると、MySQL データベースのスナップショットがキャプチャされるとともにテーブルの変更が追跡され、Fabric でのこのデータのリアルタイム処理と分析が可能です。
- Azure Cosmos DB CDC:Microsoft Fabric Eventstream 用の Azure Cosmos DB CDC コネクタを使用すると、Fabric 内での分析と処理のために、Cosmos DB 内でのリアルタイムのデータ変更がキャプチャおよび追跡されます。
- Google Cloud Pub/Sub:アプリケーションやサービス間でイベント データを交換するためのメッセージング サービス。
- Amazon Kinesis データ ストリーム:リアルタイムのストリーミング データを収集し、処理し、分析します。
- Confluent Cloud Kafka:ストリーム処理用の Apache Kafka に基づくフルマネージド サービス。
- Fabric ワークスペース イベント:Fabric ワークスペース イベントは、項目の作成、更新、削除など、Fabric ワークスペースの変更によってトリガーされるイベントです。 Fabric イベント ストリームを使用すると、Fabric 内での詳細な分析と監視のために、これらのイベントをキャプチャ、変換、およびルーティングできます。 この統合により、ワークスペース アクティビティを追跡し把握する柔軟性が強化されます。
- Azure Blob Storage イベント:Azure Blob Storage イベントは、BLOB の作成、交換、削除などのアクションのシステム トリガーです。 Microsoft Fabric Eventstream を使用すると、これらのアクションが Fabric イベントにリンクされ、Fabric 内でのルーティングと分析のために、Blob Storage イベントを継続的なデータ ストリームとして処理することができます。 Azure Blob Storage イベントに固有の特性の 1 つは、またはストリーミング解除イベントのサポートです。
- カスタム エンドポイント:Microsoft Fabric によって提供される REST API またはソフトウェア開発キット (SDK) を使用して、カスタム アプリから Eventstream にイベント データを送信できます。 カスタム アプリのデータ形式とコンシューマー グループを指定することもできます。
- サンプル データ: サンプル データは、Microsoft Fabric によって提供されるすぐに使用できるサンプル データを使用できるようにするソースです。 IoT、Retail、Finance など、さまざまなサンプル データ セットから選択できます。 サンプル データ生成の頻度と期間を調整することもできます。
ヒント
サポートされているソースの詳細については、「Fabric リアルタイム ハブのサポートされているソース」を参照してください。
Eventstream の宛先
Microsoft Fabric イベント ストリームは、拡張モードで次の宛先にデータを送信する機能もサポートしています。
- Eventhouse:この宛先は、リアルタイム イベント データを KQL データベースに取り込む機能を備えており、Kusto 照会言語 (KQL) を使用してデータの調査と分析を行うことができます。 KQL データベースにデータを格納すると、イベント データの理解が深まるだけではなく、包括的なレポートやダッシュボードを作成することもできます。
- レイクハウス:この宛先では、リアルタイム イベントをレイクハウスへ取り込む前に前処理できます。 これらのイベントは Delta Lake 形式に変換された後、特定のレイクハウス テーブル内に保存され、データ ウェアハウスのニーズに役立ちます。
- カスタム エンドポイント:この機能により、リアルタイム イベント トラフィックを特注のアプリケーションにシームレスに送信することができます。 これにより、独自のアプリケーションとイベント ストリームとの統合が可能になり、イベント データをすぐに使用できるようになります。 この機能は、Microsoft Fabric 上でホストされていない独立したシステムにリアルタイム データを転送することを目的とする場合に有益です。
- 派生ストリーム:派生ストリームは、フィルターやフィールドの管理のようなストリーム操作を適用した後に作成される特別な宛先です。 これは、処理後に変更された既定のストリームを表し、Fabric 内のさまざまな宛先にルーティングしたり、リアルタイム ハブで監視したりすることができます。
- Fabric アクティベーター:この宛先を使用すると、Fabric Activator を使用して、ストリーミング データの値に基づき、自動化されたアクションをトリガーできます。
ヒント
サポートされているソースの詳細については、「イベントストリームの宛先を追加および管理する」を参照してください。
相互の影響や衝突を起こすことなく、イベント ストリーム内の複数の宛先に同時にアタッチできるようになりました。