Real-Time ハブでソースとして Azure Cosmos DB CDC を追加する (プレビュー)

この記事では、Azure Cosmos DB for NoSQL の Change Data Capture (CDC) を Fabric リアルタイム ハブのイベント ソースとして追加する方法について説明します。

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

前提条件

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

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

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

1. Azure ポータル上の Azure Cosmos DB アカウントのページで、左側のナビゲーションの [設定] の下の [キー] を選択します。

2. [キー] ページで、イベントストリーム接続の設定に使用する URI と主キーの値をコピーします。

   

3. Azure ポータルの Azure Cosmos DB アカウントの [概要] ページで、データを収集するデータベースとアイテム ID をメモします。

   

Azure Cosmos DB CDC からイベントを取得する

Azure Cosmos DB CDC からReal-Time ハブにイベントを取り込むには、次のいずれかの方法があります。

• イベントの取得エクスペリエンスの使用
• [マイクロソフト ソース] タブ] タブの使用

イベントの取得エクスペリエンスを開始する

1. Microsoft Fabric で、[リアルタイム インテリジェンス] エクスペリエンスに切り替えます。 左側のナビゲーション バーでMicrosoft Fabricを選択し、[リアルタイム インテリジェンス]を選択します。

   

2. 左側のナビゲーション バーで[リアルタイム ハブ]を選択します。

   

3. [リアルタイム ハブ] ページで、ページの右上隅にある [+ イベントの取得] を選択します。

   

「ソースとして Azure Cosmos DB CDC を追加する」セクションの手順を実行します。

[Microsoft ソース] タブ

1. Real-Time ハブで、[Microsoft ソース] タブに切り替えます。

2. [ソース] ドロップダウン リストで、[Azure Cosmos DB (CDC)] を選択します。

3. [サブスクリプション] で、お使いの Cosmos DB アカウントを持つリソース グループを含む Azure サブスクリプションを選択します。

4. [リソース グループ] では、お使いの Cosmos DB アカウントのあるリソース グループを選択します。

5. [リージョン] では、Cosmos DB のある場所を選択します。

6. 次に、データベースの一覧で Real-Time ハブに接続する Cosmos DB CDC ソースの名前の上にマウスを移動し、[接続] ボタンを選択するか、[...] (省略記号)、[接続ボタン] の順に選択します。

   

   接続情報を構成するには、「ソースとして Azure Cosmos DB CDC を追加する」セクションの手順を実行します。 イベントの取得ウィザードで、ソースの種類として Azure Cosmos DB CDC を選択する最初の手順をスキップします。

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

1. [データソースの選択] 画面で、[Azure Cosmos DB (CDC)] を選択します。

   

2. Azure portal で Azure Cosmos DB アカウントに移動する場合は、[リソースに移動] リンクを選択します。

   

3. [接続] ページで、[新しい接続] を選択します。

   

4. [接続設定] セクションで、Cosmos DB エンドポイントを指定します。 Azure portal からコピーした Cosmos DB アカウントの URI またはエンドポイントを入力します。

   

5. [詳細オプション] を展開し、次の手順に従ってください。

   1. [再試行回数] で、要求が回復可能なエラーから失敗した場合に、コネクタが Cosmos DB データベースに要求を再送信する最大回数を指定します。

   2. [AVERAGE 関数のパス ダウンを有効にする] で、コネクタが AVG 集計関数を Cosmos DB データベースに渡すかどうかを指定します。

   3. [複数列の SORT パス ダウンを有効にする] では、SQL クエリの ORDER BY 句で複数の列が指定された際、コネクタが Cosmos DB にそれらを渡すことを許可するかどうかを指定します。

      

6. 下にスクロールし、[接続の証明書] セクションで、次の手順に従います。

   1. 既存の接続を選択し、既定の [新しい接続の作成] オプションをそのまま使用します。
   2. 接続の作成には、以下の値を入力します。

      1. [接続名] には、接続の名前を入力します。

      2. [認証の種類] には、[アカウント キー] を選択します。

      3. [アカウント キー] に先ほど保存したキー値を入力します。

      4. [接続] を選択します。

         

7. 次に、[接続] ページで次の手順を実行します。

   1. Azure Cosmos DB アカウント内のコンテナーのコンテナー ID を指定します。 1.

   2. 右側の [ストリームの 詳細 ] セクションで、ウィザードで作成するイベントストリームを保存するFabric ワークスペース を選択します。

   3. [イベントストリーム名] にイベントストリーム名を入力します。 ウィザードは、選択した Azure Cosmos DB CDC をソースとして使用してイベントストリームを作成します。

   4. ストリーム名は、イベントストリームの名前に -stream を追加することで自動的に生成されます。 ウィザードが終了すると、このストリームは リアルタイム ハブの データ ストリーム タブに表示されます。

   5. [次へ] を選択します。

      

8. 表示された [確認と作成] タブで概要を確認し、[ソースを作成] を選びます。

   

データ ストリームの詳細を表示する

1. [レビューと作成] ページで [イベントストリームを開く] を選択すると、ウィザードによって、選択した Azure Cosmos DB CDC をソースとして作成されたイベントストリームが開きます。 ウィザードを閉じるには、[閉じる] またはページの右上隅の [X]* を選択します。

   

2. リアルタイム ハブで、リアルタイム ハブの [データ ストリーム] タブに切り替えます。 ページを最新の情報に更新します。 次の図に示すように、作成されたデータ ストリームが表示されるはずです。

   

   詳細な手順については、「Fabric リアルタイム ハブでのデータ ストリームの詳細の表示」を参照してください。

関連するコンテンツ

データ ストリームの使用について詳しくは、次の記事を参照してください。

• データ ストリームの処理
• データ ストリームを分析する
• データ ストリームにアラートを設定する