次の方法で共有

Fabric リアルタイム ハブの概要 (プレビュー)

  • [アーティクル]

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

Note

リアルタイム ハブは現在プレビュー段階です。

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

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

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

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

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

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

   
他のクラウドからのデータのストリーミング
  • Google Cloud Pub/Sub
  • Amazon Kinesis Data ストリーム
Kafka クラスター
  • Confluent Cloud Kafka
  • Apache Kafka
  • Apache Kafka 用 Amazon マネージド ストリーミング
データベース変更データ キャプチャ (CDC) フィード
  • CDC Azure SQL Database
  • PostgreSQL データベースの CDC
  • Azure Cosmos DB の CDC
  • MySQL Database CDC
  • Azure SQL Managed Instance CDC
  • VM DB CDC 上の SQL Server
Microsoft ストリーミング ソース
  • Azure Event Hubs
  • IoT Hub
Fabric イベント
  • Azure Storage アカウント
  • ファブリック ワークスペース項目イベント
    自動生成

統合された イベント の取得エクスペリエンスにより、これらのソースを eventstream、KQL データベース、データ アクティベーターなどのリアルタイム ハブのコンポーネントに簡単に接続できます。

データ統合

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

    実行中のイベントストリームと 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 イベントに対してアクションを実行するには、条件に基づいてアラートを設定し、条件が満たされたときに実行するアクションを指定します。

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

関連するコンテンツ

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