リアルタイム ハブは、Fabric でストリーミング データを検出して管理するために使用されます。 リアルタイムハブを使用してストリーミングデータを取り込むことは、Fabricでデータをシームレスに統合するための最初のステップであり、これによりアナリストはデータからリアルタイムのインサイトを抽出することが可能になります。 利用可能なコネクタの豊富なセットは、ストリーミングソースに関係なく、Fabricにデータを簡単にインポートできることを保証します。
このユーザー フローでは、データ エンジニアがさまざまなストリーミング ソースからリアルタイム ハブにイベントを読み込んで変換する方法を示しています。
手順
リアルタイム ハブに移動し、[イベントの取得] を選択します。
サポートされているコネクタが表示されます。 ストリーミング ソースの場所に基づきコネクタを選択します。
資格情報などの、ソースへの接続を指定します。
ストリームに名前をつけます。 新しいイベントストリームが作成され、データのフローが開始します。
詳細と手順については、「サポートされているソースからイベントを取得する」を参照してください。
新しく作成したイベントストリームを開きます。
ストリーミング データを変換するデータ処理操作の定義をします。
ストリームに目的地を追加します。
サポートされているコネクタ
Microsoftのソース
| ソース | 説明 | 詳細情報 |
|---|---|---|
| Azure Event Hubs | フル マネージドのリアルタイム データ インジェスト サービス。 | 詳細情報 |
| Azure Service Bus (プレビュー) | 信頼性の高い通信のためのメッセージング サービス。 | 詳細情報 |
| Azure IoT Hub | IoT デバイスとデータを管理するためのプラットフォーム。 | 詳細情報 |
| Azure SQL Database CDC | データベースの変更をリアルタイムでキャプチャしてストリーミングします。 | 詳細情報 |
| AzureのPostgreSQL用データベースCDC | PostgreSQL データベースから変更をストリーム配信します。 | 詳細情報 |
| Azure Database for MySQL のCDC | MySQL データベースから変更をストリーム配信します。 | 詳細情報 |
| Azure Cosmos DB の CDC | Cosmos DB からの変更をストリーム配信します。 | 詳細情報 |
| Azure SQL Managed Instance CDC | SQL Managed Instances からの変更をキャプチャします。 | 詳細情報 |
| VM DB CDC で実行される SQL Server | VM 上の SQL Server から変更をストリーミングします。 | 詳細情報 |
| Azure Data Explorer | 大量のデータをリアルタイムで分析します。 | 詳細情報 |
外部ソース
| 外部ソース | 説明 | 詳細情報 |
|---|---|---|
| Google Cloud Pub/Sub | リアルタイム イベント ストリーミング用のメッセージング サービス。 | 詳細情報 |
| Amazon Kinesis データストリーム | リアルタイムデータ処理のためのプラットフォーム。 | 詳細情報 |
| Confluent Cloud Kafka | イベント ストリーミング用のクラウドネイティブ Kafka サービス。 | 詳細情報 |
| Apache Kafka (プレビュー) | 分散イベント ストリーミング プラットフォーム。 | 詳細情報 |
| Apache Kafka のための Amazon マネージド ストリーミング | ストリーミング用のマネージド Kafka サービス。 | 詳細情報 |
| MQTT | IoT 用の軽量メッセージング プロトコル。 | 詳細情報 |
| Solace PubSub+ | リアルタイム メッセージング用の高度なイベント ブローカー。 | 詳細情報 |
| リアルタイムの天気 | リアルタイム気象データのソース。 | 詳細情報 |
個別イベント:
| イベント元 | 説明 |
|---|---|
| Azure Blob Storage のイベント | Azure Blob Storage からイベントをキャプチャして処理する方法について説明します。 |
| Fabric ワークスペース アイテムのイベント発生 | Fabric ワークスペース項目のイベントを操作する方法について説明します。 |
| Fabric OneLake イベント | Fabric OneLake のイベント処理について説明します。 |
| Fabric ジョブ イベント | Fabric ジョブ イベントを効果的に管理および処理します。 |
考えられるユース ケース
ストリーミング データ ソースは Confluent Kafka クラスター内にあり、それを Fabric に取り込む必要があります。 リアルタイム ハブの "GetEvents" エクスペリエンスを使用することで、Confluent Kafka クラスターから Fabric にデータを簡単に取り込めます。