Azure SQL Managed Instance CDC ソースをイベントストリームに追加する

2025-06-05

この記事では、Azure SQL Managed Instance 変更データキャプチャ (CDC) ソースをイベントストリームに追加する方法を示します。

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

注

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

前提条件

共同作成者以上の権限を使用した Fabric 容量ライセンスモード (または試用版ライセンスモード) でのワークスペースへのアクセス。
稼働中の Azure SQL Managed Instance データベース。
Azure SQL Managed Instance はパブリックエンドポイントを有効化する必要があり、ファイアウォールの内側にあったり、仮想ネットワーク内でセキュリティ保護されたりしないようにする必要があります。
ストアドプロシージャ sys.sp_cdc_enable_db を実行して Azure SQL Managed Instance 内で有効化された CDC。変更データキャプチャを有効および無効にする。

Azure SQL マネージドインスタンス内でパブリックエンドポイントを有効にする

Azure portal に移動し、Azure SQL Managed Instance を開き、[ネットワーク] を選択して、パブリックエンドポイントを有効化します。

Azure SQL Azure SQL Managed Instance 内で CDC を有効化する

データベースに対して CDC を有効化します。
```
EXEC sys.sp_cdc_enable_db; 
```
ゲーティングロールオプションを使用して、テーブルに対して CDC を有効にします。この例では、MyTable は SQL テーブルの名前です。
```
EXEC sys.sp_cdc_enable_table 
   @source_schema = N'dbo', 
   @source_name   = N'MyTable', 
   @role_name     = NULL 
GO 
```
クエリが正常に実行された後、Azure SQL マネージドインスタンス内で CDC を有効にしました。

Azure SQL Managed Instance CDC をソースとして追加する

Fabric Real-Time Intelligence で、[イベントストリーム] を選択して新しいイベントストリームを作成します。
次の画面で、外部ソースの追加を選択します。

Azure SQL Managed Instance CDC を構成して接続する

データ接続ページで、新しい接続を選択します。
[接続設定] セクションで、VM 上の SQL Server について次の値を入力します。
- サーバー: Azure portal からのエンドポイントを入力し、ホストとポートの間のコンマをコロンに置き換えます。たとえば、エンドポイントが xxxxx.public.xxxxxx.database.windows.net,3342 の場合は、xxxxx.public.xxxxxx.database.windows.net:3342 フィールドに「」と入力する必要があります。
- データベース: Azure SQL Managed Instance 内の接続先データベースの名前を入力します。
下にスクロールし、[接続資格情報] セクションで、次の手順に従います。
- 接続名 には、接続の名前を入力します。
- [認証の種類] で、[Basic] を選択します。
  
  注
  
  現在、ファブリックイベントストリームはBasic認証のみをサポートしています。
- VM 上の SQL Server の [ユーザー名] と [パスワード] を入力します。
ページの下部にある [接続] を選びます。
[ 接続 ] ページで、[ すべてのテーブル ] または [ テーブル名の入力] を選択します。後者を選択する場合は、完全なテーブル識別子 (schemaName.tableName) または有効な正規表現のコンマ区切りの一覧を使用してテーブルを指定します。例えば次が挙げられます。
- dbo.test.*を使用して、名前が dbo.test で始まるすべてのテーブルを選択します。
- dbo\.(test1|test2)を使用して、dbo.test1とdbo.test2を選択します。
両方の形式をコンマで混在させることができます。完全なテーブル識別子を直接使用する場合は、各テーブル名 (スキーマ名を含む) を 128 文字に制限して、最大 100 個のテーブルを入力できます。
[詳細設定] を展開して、[小数処理モード]を構成できます。このモードでは、コネクタがDECIMALおよびNUMERICの列の値をどのように処理するかを指定します。
- Precise: 正確な 10 進型 (Java BigDecimal など) を使用して値を表し、データ表現の完全な精度と精度を確保します。
- Double: 値を倍精度浮動小数点数に変換します。これにより、使いやすさとパフォーマンスが向上しますが、精度が失われる可能性があります。
- String: 値を書式設定された文字列としてエンコードします。これにより、ダウンストリームシステムで簡単に使用できますが、元の数値型に関するセマンティック情報は失われます。
[次へ] を選択します。
[確認と接続] ページで概要を確認してから、[接続] を選択します。