イベントストリーム のイベント ソースを追加および管理する
イベントストリーム を作成したら、それをさまざまなデータ ソースと宛先に接続することができます。
Note
プレビュー段階の拡張機能を使用する場合は、上部にある [拡張機能] を選択します。 それ以外の場合は、[Standard機能] を選択します。 プレビュー段階の拡張機能の詳細については、「Fabric イベント ストリームの概要」を参照してください。
イベントストリーム を作成したら、それをさまざまなデータ ソースと宛先に接続することができます。
Eventstream を使用すると、Microsoft ソースからデータをストリーミングできるだけでなく、Google Cloud や Amazon Kinesis などのサードパーティプラットフォームからのインジェストと新しいメッセージング コネクタをサポートします。 この拡張された機能により、外部データ ストリームを Fabric にシームレスに統合できるため、柔軟性が向上し、複数のソースからリアルタイムの分析情報を得ることができます。
この記事では、プレビュー段階にある強化された機能を使用して eventstream に追加できるイベント ソースについて説明します。
重要
Fabric イベント ストリームの拡張機能は現在プレビュー段階です。
前提条件
- 投稿者以上の権限を持つ Fabric プレミアム ワークスペースへのアクセス権
- 次のソース固有の記事に記載されている各ソースに固有の前提条件。
サポートされているソース
強化された機能を備えたファブリック イベント ストリームでは、次のソースがサポートされます。 各記事では、特定のソースを追加するための詳細と手順について説明します。
| ソース | 説明 |
|---|---|
| Azure Event Hubs | Azure イベント ハブがある場合は、イベントストリーム を使用してイベント ハブ データを Microsoft Fabric に取り込むことができます。 |
| Azure IoT Hub | Azure IoT ハブがある場合は、イベントストリーム を使用して IoT データを Microsoft Fabric に取り込むことができます。 |
| Azure SQL データベースの変更データ キャプチャ (CDC) | Azure SQL データベース CDC ソース コネクタを使用すると、Azure SQL データベース内の現在のデータのスナップショットをキャプチャできます。 コネクタは、このデータに対する将来の行レベルの変更を監視し、記録します。 |
| PostgreSQL データベースの CDC | PostgreSQL データベース変更データ キャプチャ (CDC) ソース コネクタを使用すると、PostgreSQL データベース内の現在のデータのスナップショットをキャプチャできます。 コネクタは、このデータに対する将来の行レベルの変更を監視し、記録します。 |
| MySQL Database CDC | Azure MySQL データベース変更データ キャプチャ (CDC) ソース コネクタを使用すると、Azure Database for MySQL データベース内の現在のデータのスナップショットをキャプチャできます。 監視するテーブルを指定でき、eventstream はテーブルに対する将来の行レベルの変更を記録します。 |
| Azure Cosmos DB の CDC | Microsoft Fabric イベントストリーム用の Azure Cosmos DB Change Data Capture (CDC) ソースコネクタを使用すると、Azure Cosmos DB データベース内の現在のデータのスナップショットを取得できます。 コネクタは、このデータに対する将来の行レベルの変更を監視し、記録します。 |
| Google Cloud Pub/Sub | Google Pub/Sub は、イベントのストリームを公開してサブスクライブできるメッセージング サービスです。 Google Pub/Sub をソースとしてイベントストリームに追加して、リアルタイムイベントをキャプチャ、変換し、ファブリック内のさまざまな宛先にルーティングできます。 |
| Amazon Kinesis Data ストリーム | Amazon Kinesis Data ストリーム は、ストリーミング データ用に最適化された、非常にスケーラブルで耐久性の高いデータ インジェストおよび処理サービスです。 Amazon Kinesis Data ストリームをイベントストリーム内のソースとして統合することで、リアルタイムデータストリームをファブリック内の複数の宛先にルーティングする前にシームレスに処理できます。 |
| Confluent Cloud Kafka | Confluent Cloud Kafka は、Apache Kafka を使用した強力なデータ ストリーミングと処理機能を提供するストリーミング プラットフォームです。 Confluent Cloud Kafka をイベントストリーム内のソースとして統合することで、リアルタイム データ ストリームをシームレスに処理してから、Fabric 内の複数の宛先にルーティングできます。 |
| Azure Blob Storage のイベント | これらのイベントは、クライアントが BLOB REST API を呼び出して BLOB を作成、置換、または削除するときにトリガーされます。 コネクタを使用すると、Blob Storage イベントをリアルタイム ハブの Fabric イベントにリンクできます。 これらのイベントを連続データ ストリームに変換し、それらを変換してから、Fabric のさまざまな宛先にルーティングできます。 |
| Fabric Workspace Item イベント | Fabric ワークスペース項目イベントは、Fabric ワークスペースに変更が加えられたときに発生する個別の Fabric イベントです。 これらの変更には、Fabric アイテムの作成、更新、または削除が含まれます。 Fabric イベント ストリームを使用すると、これらの Fabric ワークスペース イベントをキャプチャし、それらを変換し、さらに分析するために Fabric のさまざまな宛先にルーティングできます。 |
| サンプル データ | サンプル データ ソースとして Bicycles、Yellow Taxi、または Stock Market イベントを選択して、イベントストリームの設定中にデータ インジェストをテストできます。 |
| カスタム エンドポイント (すなわち、標準機能のカスタム アプリ) | カスタム エンドポイント機能を使用すると、アプリケーションまたは Kafka クライアントは接続文字列を使用して イベントストリーム に接続できるため、イベントストリーム へのストリーミング データのスムーズな取り込みを可能にします。 |
Note
1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。
関連するコンテンツ
前提条件
開始する前に、次の前提条件を満たしている必要があります。
- イベントストリーム が配置されている Premium ワークスペースに、投稿者以上のアクセス許可を使用してアクセスします。
- Azure Event Hubs または Azure IoT Hub を イベントストリーム ソースとして追加するには、そのポリシー キーにアクセスするための適切なアクセス許可が必要です。 これは、パブリックにアクセス可能であり、ファイアウォールの内側や、仮想ネットワークで保護されいない必要があります。
サポートされているソース
Fabric イベント ストリームでは、次のソースがサポートされています。 テーブルのリンクを使用して、特定のソースの追加に関する詳細を提供する記事に移動します。
| ソース | 説明 |
|---|---|
| Azure Event Hubs | Azure イベント ハブがある場合は、イベントストリーム を使用してイベント ハブ データを Microsoft Fabric に取り込むことができます。 |
| Azure IoT Hub | Azure IoT ハブがある場合は、イベントストリーム を使用して IoT データを Microsoft Fabric に取り込むことができます。 |
| サンプル データ | サンプル データ ソースとして Bicycles、Yellow Taxi、または Stock Market イベントを選択して、イベントストリームの設定中にデータ インジェストをテストできます。 |
| カスタム アプリ | カスタム アプリ機能を使用すると、アプリケーションまたは Kafka クライアントは接続文字列を使用して イベントストリーム に接続できるため、イベントストリーム へのストリーミング データのスムーズな取り込みを可能にします。 |
Note
1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。
ソースを管理する
編集/削除: ナビゲーション ウィンドウまたはキャンバスで イベントストリーム ソースを選択して、編集または削除することができます。 [編集] を選択すると、メイン エディターの右側に編集ペインが開きます。
カスタム アプリのキーの再生成: アプリケーションの新しい接続キーを再生成する必要がある場合は、キャンバスでいずれかのカスタム アプリ ソースを選択し、[再生成] を選択して、新しい接続キーを取得します。
関連するコンテンツ
フィードバック
以下は間もなく提供いたします。2024 年を通じて、コンテンツのフィードバック メカニズムとして GitHub の issue を段階的に廃止し、新しいフィードバック システムに置き換えます。 詳細については、「https://aka.ms/ContentUserFeedback」を参照してください。
フィードバックの送信と表示