Azure SQL Database CDC ソースを eventstream に追加する

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

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

前提条件

共同作成者以上のアクセス許可を使用した Fabric 容量ライセンスモード (または試用版ライセンスモード) でのワークスペースへのアクセス。
Azure SQL データベースを備えた実行中の Azure SQL サーバー。
Azure Event Hubs と Azure SQL Database のリソースは、パブリックにアクセスでき、ファイアウォールの内側に配置されておらず、また Azure Virtual Network 内でセキュリティ保護されていない必要があります。
ストアドプロシージャ sys.sp_cdc_enable_db を実行して、Azure SQL データベースで CDC を有効にしました。変更データキャプチャを有効および無効にする。
イベントストリームがない場合は、イベントストリームを作成します。

Azure SQL データベースでミラーリングを有効にしてはならないことに注意してください。

Azure SQL データベースで CDC を有効にする

Azure portal に移動し、Azure SQL データベースを開き、[クエリエディター] を選択します。ログインするための認証方法を選びます。

次の SQL コマンドを実行して、データベースで CDC を有効にします。

-- Enable Database for CDC
EXEC sys.sp_cdc_enable_db;

-- Enable CDC for a table using a gating role option
EXEC sys.sp_cdc_enable_table
    @source_schema = N'dbo',
    @source_name   = N'MyTable',
    @role_name     = NULL
GO

データソースの選択ウィザードを起動する

まだイベントストリームにソースを追加していない場合は、[ 外部ソースを使用 ] タイルを選択します。

既に公開されているイベントストリームにソースを追加する場合は、編集モードに切り替えます。リボンで、[ソース>の追加] を選択します。

[データソースの選択] ページにおいて、[Azure SQL DB (CDC)] タイルで [接続] を探して選択します。

Azure SQL データベース接続を構成します。

データ接続ページで、新しい接続を選択します。
[接続設定] セクションで、Azure SQL データベースの次の値を入力します。
- Azure Portal からサーバー名を入力しますこれは、mysqlservername.database.windows.net という形式です。
- データベース： Azure portal から Azure SQL データベース名を入力します。
下にスクロールし、[接続資格情報] セクションで、次の手順に従います。
- 接続名 には、接続の名前を入力します。
- [認証の種類] で、[Basic] を選択します。
  
  注
  
  現時点では、Fabric Eventstream では基本認証のみがサポートされています。
- データベースで、[ユーザー名] と [パスワード] を入力します。
接続を選択します。
[ 接続 ] ページで、[ すべてのテーブル] または [ テーブル名の入力] を選択します。後者を選択する場合は、完全なテーブル識別子 (schemaName.tableName) または有効な正規表現のコンマ区切りの一覧を使用してテーブルを指定します。例えば次が挙げられます。
- dbo.test.*を使用して、名前が dbo.test で始まるすべてのテーブルを選択します。
- dbo\.(test1|test2)を使用して、dbo.test1とdbo.test2を選択します。
両方の形式をコンマで混在させることができます。エントリ全体の文字制限の合計は 102,400 文字です。
[詳細設定] を展開して、Azure SQL Database CDC ソースの追加の構成オプションにアクセスできます。
- 10 進処理モード: コネクタが DECIMAL と NUMERIC 列の値を処理する方法を定義します。
  - Precise: 正確な 10 進型 (Java BigDecimal など) を使用して値を表し、データ表現の完全な精度と精度を確保します。
  - Double: 値を倍精度浮動小数点数に変換します。この設定により、使いやすさとパフォーマンスが向上しますが、精度が低下する可能性があります。
  - String: 値を書式設定された文字列としてエンコードします。この設定により、ダウンストリームシステムで簡単に使用できますが、元の数値型に関するセマンティック情報は失われます。
- スナップショットモード: コネクタの起動時にスナップショットを実行するための条件を指定します。
  - Initial: コネクタは、論理サーバー名のオフセットが記録されていない場合、または以前のスナップショットが完了しなかったことを検出した場合にのみ、スナップショットを実行します。スナップショットが完了すると、コネクタは後続のデータベース変更のイベントレコードのストリーミングを開始します。
  - InitialOnly: コネクタは、論理サーバー名のオフセットが記録されていない場合にのみスナップショットを実行します。スナップショットが完了すると、コネクタは停止します。 binlog から変更イベントを読み取るためにストリーミングに移行することはありません。
  - NoData: コネクタは、スキーマのみをキャプチャするスナップショットを実行しますが、テーブルデータはキャプチャしません。データの一貫性のあるスナップショットは必要ありませんが、コネクタの起動後に発生する変更のみが必要な場合は、このオプションを設定します。
- 列除外リスト: 完全修飾名 (schemaName.tableName.columnName) を使用して変更イベント値から除外する列を指定します。
- データベースアプリケーションインテント: SQL Server Always On 可用性グループにおけるルーティング動作を決定します。
  - ReadWrite: プライマリレプリカに接続します。これは、接続で読み取り操作と書き込み操作の両方を実行する必要がある場合に使用します。
  - ReadOnly: 読み取り専用操作のために読み取り可能なセカンダリレプリカへのルーティングを許可します。これを使用して、レプリカで CDC を直接有効にします。 snapshot.isolation.mode をスナップショットに設定する必要があります。これは、読み取り専用レプリカでサポートされる唯一のトランザクション分離モードです。
- スナップショット選択ステートメントのオーバーライド: スナップショットにテーブル内の行のサブセットのみを含める場合は、このプロパティを使用します。このプロパティはスナップショットにのみ影響します。コネクタがログから読み取るイベントには適用されません。
[次へ] を選択します。
[確認と作成] 画面で、概要を確認し、[追加] を選択します。

CDC を介した自動テーブルスキーマ登録を使用して Azure SQL データベースから Eventstream に変更データを取り込みます。

データ接続ページで、新しい接続を選択します。
[接続設定] セクションで、Azure SQL データベースの次の値を入力します。
- Azure Portal からサーバー名を入力しますこれは、mysqlservername.database.windows.net という形式です。
- データベース： Azure portal から Azure SQL データベース名を入力します。
下にスクロールし、[接続資格情報] セクションで、次の手順に従います。
- 接続名 には、接続の名前を入力します。
- [認証の種類] で、[Basic] を選択します。
  
  注
  
  現時点では、Fabric Eventstream では基本認証のみがサポートされています。
- データベースで、[ユーザー名] と [パスワード] を入力します。
接続を選択します。
[ 接続 ] ページで、[ すべてのテーブル] または [ テーブル名の入力] を選択します。後者を選択する場合は、完全なテーブル識別子 (schemaName.tableName) または有効な正規表現のコンマ区切りの一覧を使用してテーブルを指定します。例えば次が挙げられます。
- dbo.test.*を使用して、名前が dbo.test で始まるすべてのテーブルを選択します。
- dbo\.(test1|test2)を使用して、dbo.test1とdbo.test2を選択します。
両方の形式をコンマで混在させることができます。エントリ全体の文字制限の合計は 102,400 文字です。
[詳細設定] を展開して、Azure SQL Database CDC ソースの追加の構成オプションにアクセスできます。
- 10 進処理モード: コネクタが DECIMAL と NUMERIC 列の値を処理する方法を定義します。
  - Precise: 正確な 10 進型 (Java BigDecimal など) を使用して値を表し、データ表現の完全な精度と精度を確保します。
  - Double: 値を倍精度浮動小数点数に変換します。この設定により、使いやすさとパフォーマンスが向上しますが、精度が低下する可能性があります。
  - String: 値を書式設定された文字列としてエンコードします。この設定により、ダウンストリームシステムで簡単に使用できますが、元の数値型に関するセマンティック情報は失われます。
- スナップショットモード: コネクタの起動時にスナップショットを実行するための条件を指定します。
  - Initial: コネクタは、論理サーバー名のオフセットが記録されていない場合、または以前のスナップショットが完了しなかったことを検出した場合にのみ、スナップショットを実行します。スナップショットが完了すると、コネクタは後続のデータベース変更のイベントレコードのストリーミングを開始します。
  - InitialOnly: コネクタは、論理サーバー名のオフセットが記録されていない場合にのみスナップショットを実行します。スナップショットが完了すると、コネクタは停止します。 binlog から変更イベントを読み取るためにストリーミングに移行することはありません。
  - NoData: コネクタは、スキーマのみをキャプチャするスナップショットを実行しますが、テーブルデータはキャプチャしません。データの一貫性のあるスナップショットは必要ありませんが、コネクタの起動後に発生する変更のみが必要な場合は、このオプションを設定します。
- 列除外リスト: 完全修飾名 (schemaName.tableName.columnName) を使用して変更イベント値から除外する列を指定します。
- データベースアプリケーションインテント: SQL Server Always On 可用性グループにおけるルーティング動作を決定します。
  - ReadWrite: プライマリレプリカに接続します。これは、接続で読み取り操作と書き込み操作の両方を実行する必要がある場合に使用します。
  - ReadOnly: 読み取り専用操作のために読み取り可能なセカンダリレプリカへのルーティングを許可します。これを使用して、レプリカで CDC を直接有効にします。 snapshot.isolation.mode をスナップショットに設定する必要があります。これは、読み取り専用レプリカでサポートされる唯一のトランザクション分離モードです。
- スナップショット選択ステートメントのオーバーライド: スナップショットにテーブル内の行のサブセットのみを含める場合は、このプロパティを使用します。このプロパティはスナップショットにのみ影響します。コネクタがログから読み取るイベントには適用されません。
イベントスキーマの関連付けを有効にします。
[ワークスペース] で、スキーマセットのファブリックワークスペースを選択します。
[ スキーマセット] では、[ + 作成 ] が既定で選択され、新しいスキーマセットが作成されます。既存のイベントスキーマセットを選択するように変更できます。
前の手順で [+ 作成 ] オプションを選択した場合は、スキーマセットの名前を入力します。
[確認と接続] ページで [追加] を選択します。

Azure SQL データベース内のすべてのテーブルまたは選択したテーブルに対して、コネクタはスキーマを自動検出して作成し、スキーマレジストリに登録します。
中央の イベントストリーム ノードを選択し、下部ウィンドウの [ 関連付けられたスキーマ ] タブに切り替えます。

スキーマセット

前の手順で選択したワークスペースに移動します。次の例では、 個人用ワークスペースです。
Azure SQL Database (CDC) コネクタが作成したスキーマセットを選択します。
次の図に示すように、スキーマセットにスキーマが表示されます。
スキーマの JSON バージョンを表示するには、 JSON スキーマ ビューに切り替えます。

このエディターを使用して検出されたこれらのスキーマは、Azure SQL データベースソース内のテーブルのスキーマに対して不確認になるため、変更しないでください。

更新されたイベントストリームを表示する

編集モードで Eventstream に追加された Azure SQL Database (CDC) ソースを確認できます。
この新しく追加された Azure SQL Database CDC ソースを実装するには、[発行] を選択します。これらの手順を完了すると、Azure SQL Database CDC ソースをライブビューで視覚化できるようになります。

スキーマを使用するように eventstream 送信先を構成する

現時点では、拡張機能が有効になっているイベントストリームでは、eventhouse、カスタムエンドポイント、および派生ストリーム変換先のみがサポートされています。このセクションでは、イベントストリームに対して拡張機能 (スキーマサポートなど) が有効になっている場合に、eventhouse 変換先を追加および構成する方法について説明します。

カスタムエンドポイント変換先のスキーマを構成する

[ イベントの変換] または [宛先の追加] を選択し、[ CustomEndpoint] を選択します。
[ カスタムエンドポイント ] ウィンドウで、宛先の名前を指定します。
[入力スキーマ] で、イベントのスキーマを選択します。このボックスでは、イベントストリームのスキーマサポートを有効にするときに選択します。

カスタムエンドポイントの送信先を構成する詳細な手順については、「カスタムエンドポイントまたはカスタムアプリの宛先をイベントストリームに追加する」を参照してください。

イベントハウスの宛先に対するスキーマを設定する

[ イベントの変換] または [宛先の追加] を選択し、[ Eventhouse] を選択します。
[Eventhouse] ウィンドウで、次のスキーマ関連の設定を構成します。
1. [入力スキーマ] で、ドロップダウンリストから 1 つ以上のスキーマを選択します。
  
  注
  
  Event Hubs ソースを構成するときに [ヘッダーによる動的スキーマ ] オプションを選択した場合は、ソースに対して複数のスキーマを構成し、それらをさまざまなプロパティとその値にマップしている可能性があります。
2. [テーブルの作成方法] では、要件に応じて、すべてのスキーマを結合した 1 つのテーブルを選択するか、スキーマごとに個別のテーブルを選択します。
3. [ データの書き込み方法] で、次のいずれかのオプションを選択します。
  - ペイロードのみ: 抽出されたペイロードデータをテーブルに書き込みます。複数の入力スキーマがある場合、データは複数のテーブルに送信されます。
  - メタデータとペイロード: メタデータとペイロードデータを 1 つのテーブルに書き込みます。列の例には、 source 、 subject、 type、および dataがあります。

イベントハウスの宛先を構成する詳細な手順については、「イベントストリームにイベントハウスの宛先を追加する」を参照してください。

その他のコネクタ。

フィードバック

このページはお役に立ちましたか?

Last updated on 2025-11-19

次の方法で共有

Azure SQL Database CDC ソースを eventstream に追加する

前提条件

Azure SQL データベースで CDC を有効にする

データ ソースの選択ウィザードを起動する

Azure SQL データベース接続を構成します。

スキーマ セット