次の方法で共有


Fabric リアルタイム ハブの概要

リアルタイム ハブは、組織全体のすべてのデータインモーションの単一の場所です。 すべての Microsoft Fabric テナントは、ハブで自動的にプロビジョニングされます。 セットアップまたは管理に追加の手順は必要ありません。 また、Fabric へのデータ インジェストを簡素化するための豊富なコネクタも提供します。 この記事では、これらの機能について詳しく説明します。

組織全体で移動中のデータの単一の場所

リアルタイム ハブは、移動中のデータをストリーミングするための、テナント全体で統一された単一の論理的な場所です。 これにより、さまざまなソースからのデータインモーションを簡単に検出、取り込み、管理、使用できます。 すべてのストリームと Kusto 照会言語 (KQL) テーブルが一覧表示され、直接操作できます。 また、Microsoft 製品や Fabric イベントからストリーミング データを取り込むための簡単な方法も提供されます。

テナント内の各ユーザーは、アクセス権を持つすべてのイベントまたはストリームを表示および編集できます。 リアルタイム ハブを使用すると、1 か所で簡単に共同作業を行い、ストリーミング アプリケーションを開発できます。

[すべてのデータ ストリーム] が選択されている [リアルタイム ハブ] ページを示すスクリーンショット。

さまざまなソースからデータを取り込むための多数のコネクタ

リアルタイム ハブには、さまざまなソースから Microsoft Fabric にデータを簡単に取り込むための、すぐに使用できるコネクタが多数用意されています。 リアルタイム ハブでは、次のコネクタがサポートされています。

   
他のクラウドからのデータのストリーミング
  • Google Cloud Pub/Sub
  • Amazon Kinesis Data ストリーム
Kafka クラスター
  • Confluent Cloud Kafka
  • Apache Kafka
  • Amazon Managed Streaming for Apache Kafka
データベース変更データ キャプチャ (CDC) フィード
  • CDC Azure SQL Database
  • PostgreSQL データベースの CDC
  • MySQL Database CDC
  • Azure Cosmos DB の CDC
  • Azure SQL Managed Instance CDC
  • SQL Server on Virtual Machine (VM) DB CDC
Microsoft ストリーミング ソース
  • Azure Event Hubs
  • Azure Service Bus
  • Azure IoT Hub
Fabric イベント Fabric ワークスペース アイテムのイベント (自動生成)
Azure のイベント Azure Storage アカウント

リアルタイム ハブを使えば、これらのソースを、イベントストリーム、KQL データベース、Fabric Activator などのリアルタイム ハブのコンポーネントに簡単に接続できます。

データ統合

  • すべてのデータ ストリームとテーブル

    実行中のイベントストリームと KQL データベースについて、イベントストリームからのストリーム出力と、アクセスできる KQL データベースのテーブルが、すべて自動的にリアルタイム ハブに表示されます。

  • マイ ストリームとマイ テーブル

    リアルタイム ハブの 1 か所ですべてのストリームにアクセスできます。

  • Microsoft サービスとの統合

    リアルタイム ハブには、Microsoft サービスからのすべてのストリーミング リソースが一覧表示されます。 Azure Event Hubs、Azure IoT Hub、その他のサービスのいずれであっても、リアルタイム ハブにシームレスにデータを取り込むことができます。

  • Fabric イベント

    Fabric アーティファクトと外部ソースを介して生成されたイベントは、リアルタイムアラートやダウンストリーム アクションのトリガーなどのイベントドリブン シナリオをサポートするために Fabric で使用できます。 Fabric ワークスペース項目イベントや Azure Blob Storage イベントなどのイベントを監視して対応できます。 これらのイベントは、データ パイプラインの呼び出しや電子メールによる通知の送信など、他のアクションやワークフローをトリガーするために使用できます。 ユーザーは、Fabric イベント ストリームを介してこれらのイベントを他の宛先に送信することもできます。

データ ストリームの処理、分析、操作

リアルタイム ハブを使用すると、サポートされているソースのストリームを作成できます。 ストリームを作成したら、ストリームの処理、分析、およびそれらに対するアラートの設定を行うことができます。

  • ストリームを処理するには、エディターで親イベントストリームを開き、集計、展開、フィルター、グループ化、フィールドの管理、共用体などの変換を追加して、Fabric にストリーミングされているデータを変換または処理してから、変換からサポートされている変換先に出力データを送信します。

  • ストリームを分析するには、データ ストリームに関連付けられているイベントストリームを開き、KQL データベース変換先を追加して KQL テーブルにデータを送信し、KQL データベースを開き、KQL テーブルに対するクエリを実行します。 リアルタイム ハブのテーブルを分析するには、親 KQL データベースを開き、KQL テーブルに対してクエリを実行します。

  • ストリームまたは Fabric イベントに対してアクションを実行するには、条件に基づいてアラートを設定し、条件が満たされたときに実行するアクションを指定します。

    リアルタイム ハブ アーキテクチャの概念図を示すスクリーンショット。

「リアルタイム ハブの概要」を参照してください