SQL Server on VM DB (CDC) ソースをイベントストリームに追加する

2025-06-05

この記事では、VM DB Change Data Capture (CDC) ソース上の SQL Server をイベントストリームに追加する方法について説明します。

Fabric イベントストリーム用の SQL Server on VM DB (CDC) ソースコネクタを使うと、VM 上の SQL Server データベース内の現在のデータのスナップショットをキャプチャできます。現在、SQL Server on VM DB (CDC) は、データベースにパブリックにアクセスできる次のサービスからサポートされています。

Azure Virtual Machines における SQL Server
Amazon RDS for SQL Server
Amazon RDS Custom for SQL Server
Google Cloud SQL for SQL Server

注

AWS RDS SQL Server、AWS RDS Custom SQL Server、および Google Cloud SQL SQL Server は、Express バージョンをサポートしていません。 CDC 用の SQL Server の適切なエディションを使用していることを確認します。

SQL Server on VM DB (CDC) ソースがイベントストリームに追加されると、将来の行レベルの変更を監視して記録します。その後、リアルタイムで処理し、さまざまな宛先に送信してさらに分析できます。

注

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

前提条件

共同作成者以上のアクセス許可を使用した Fabric 容量ライセンスモード (または試用版ライセンスモード) でのワークスペースへのアクセス。
実行中の SQL Server on VM データベース。
SQL Server on VM データベースは、パブリックアクセスを許可するように構成されている必要があります。
ストアドプロシージャ sys.sp_cdc_enable_db を実行して、SQL Server on VM データベースで CDC を有効にします。変更データキャプチャを有効および無効にする。

SQL Server on VM データベースで 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 
```
クエリが正常に実行された後、SQL Server on VM データベースで CDC を有効にしました。

SQL Server on VM データベースをソースとして追加する

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

SQL Server on VM データベースを構成して接続する

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