Azure Cosmos DB CDC ソースをEventstreamに追加する (プレビュー)

[アーティクル]
06/20/2024

この記事では、Azure Cosmos DB (Azure Cosmos DB for NoSQL) 変更データキャプチャソースを Eventstream に追加する方法について説明します。

Microsoft Fabric イベントストリーム用の Azure Cosmos DB Change Data Capture (CDC) ソースコネクタを使用すると、Azure Cosmos DB データベース内の現在のデータのスナップショットを取得できます。コネクタは、このデータに対する将来の行レベルの変更を監視し、記録します。イベントストリームに変更がキャプチャされると、この CDC データをリアルタイムで処理し、Fabric 内のさまざまな宛先に送信して、さらに処理または分析することができます。

重要

Fabric イベントストリームの拡張機能は現在プレビュー段階です。

Note

このソースは、ワークスペース容量の次のリージョンではサポートされていません: 米国西部 3、スイス西部。

前提条件

投稿者 以上のアクセス許可を持つ Premium ワークスペース へのアクセス。
Azure Cosmos DB for NoSQL アカウントとデータベースへのアクセス権
Azure Cosmos DB for NoSQL データベースはパブリックにアクセス可能である必要があり、ファイアウォールや仮想ネットワークで保護されていることはできません。

Azure ポータルから接続の詳細を取得する

Azure portal から収集する必要がある項目のラベルを次の手順に示します。必ずエンドポイント URI https://<account>.<api>.azure.com:<port>/のような形式)、プライマリキー、およびデータを収集するデータベース名と項目 ID が必要です。

Note

Azure Cosmos DB for NoSQL CDC では、Azure Cosmos DB 変更フィードの最新バージョンモードが使用されています。最新バージョンのレコードへの変更をキャプチャします。このモードでは、削除はキャプチャされないことに注意してください。

Azure ポータル上の Azure Cosmos DB アカウントのページで、左側のナビゲーションの [設定] の下の [キー] を選択します。
[キー] ページで、イベントストリーム接続の設定に使用する URI と主キーの値をコピーします。
Azure ポータルの Azure Cosmos DB アカウントの [概要] ページで、データを収集するデータベースとアイテム ID をメモします。

Note

1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。

Azure Cosmos DB (CDC) をソースとして追加する

Fabric Real-Time Intelligence で、[イベントストリーム] を選択して新しいイベントストリームを作成します。 [拡張機能 (プレビュー)] オプションが有効になっていることを確認します。
次の画面で、外部ソースの追加を選択します。

Azure Cosmos DB (CDC) を構成して接続する

[データソースの選択] 画面で、[Azure Cosmos DB (CDC)] を選択します。
[接続] 画面の [接続] で、[新しい接続] を選択し、Azure Cosmos DB データベースにリンクするクラウド接続を作成します。
[接続設定] 画面で、次の情報を入力します。
- Cosmos DB エンドポイント: Azure ポータルからコピーした Cosmos DB アカウントの URI またはエンドポイントを入力します。
- 接続名: 自動生成されるか、この接続の新しい名前を入力できます。
- アカウントキー: Azure ポータルからコピーした Azure Cosmos DB アカウントのプライマリキーを入力します。
[接続] を選択します。
Azure Cosmos DB リソースに次の情報を提供します。
- コンテナー ID: 接続する Azure Cosmos DB コンテナーまたはテーブルの名前を入力します。
- データベース: Azure Cosmos DB データベースの名前を入力します。
- オフセットポリシー: コミットがない場合に、[最も早い] または [最新の] オフセットのどちらから読み取りを開始するかを選択します。
[次へ] を選択します。
概要を確認し、[追加] を選択します。