Azure Cosmos DB CDC ソースをEventstreamに追加する (プレビュー)
この記事では、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 データベースの名前を入力します。
- オフセット ポリシー: コミットがない場合に、[最も早い] または [最新の] オフセットのどちらから読み取りを開始するかを選択します。
[次へ] を選択します。
概要を確認し、[追加] を選択します。
Azure Cosmos DB (CDC) ソースが編集モードでイベントストリームに追加されます。
[公開する] を選択して変更を公開し、Azure Cosmos DB CDC データのイベントストリームへのストリーミングを開始します。
関連するコンテンツ
その他のコネクタ。