この記事では、Azure SQL データベースの変更データ キャプチャ (CDC) ソースをイベントストリームに追加する方法について説明します。
Microsoft Fabric イベント ストリーム用の PostgreSQL データベースの変更データ キャプチャ (CDC) ソース コネクタを使用すると、PostgreSQL データベース内の現在のデータのスナップショットをキャプチャできます。 コネクタは、このデータに対する将来の行レベルの変更を監視し、記録します。 イベントストリームに変更がキャプチャされると、この CDC データをリアルタイムで処理し、Fabric 内のさまざまな宛先に送信して、さらに処理または分析することができます。
注
このソースは、ワークスペース容量の次のリージョンではサポートされていません: 米国西部 3、スイス西部。
前提条件
- 共同作成者以上のアクセス許可を使用した 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] を選択します。
注
現在、ファブリック イベント ストリームはBasic認証のみをサポートしています。
データベースで、[ユーザー名] と [パスワード] を入力します。
接続 を選択します。
[ 接続 ] ページで、[ すべてのテーブル ] または [ テーブル名の入力] を選択します。 後者を選択する場合は、完全なテーブル識別子 (
schemaName.tableName
) または有効な正規表現のコンマ区切りの一覧を使用してテーブルを指定します。 例えば次が挙げられます。-
dbo.test.*
を使用して、名前がdbo.test
で始まるすべてのテーブルを選択します。 -
dbo\.(test1|test2)
を使用して、dbo.test1
とdbo.test2
を選択します。
両方の形式をコンマで混在させることができます。 完全なテーブル識別子を直接使用する場合は、各テーブル名 (スキーマ名を含む) を 128 文字に制限して、最大 100 個のテーブルを入力できます。
-
[詳細設定] を展開して、[小数処理モード]を構成できます。このモードでは、コネクタが
DECIMAL
およびNUMERIC
の列の値をどのように処理するかを指定します。-
Precise
: 正確な 10 進型 (JavaBigDecimal
など) を使用して値を表し、データ表現の完全な精度と精度を確保します。 -
Double
: 値を倍精度浮動小数点数に変換します。 これにより、使いやすさとパフォーマンスが向上しますが、精度が失われる可能性があります。 -
String
: 値を書式設定された文字列としてエンコードします。 これにより、ダウンストリーム システムで簡単に使用できますが、元の数値型に関するセマンティック情報は失われます。
-
[次へ] を選択します。
[確認と作成] 画面で、概要を確認し、[追加] を選択します。
更新されたイベントストリームを表示する
編集モードで Eventstream に追加された Azure SQL Database (CDC) ソースを確認できます。
この新しく追加された Azure SQL Database CDC ソースを実装するには、[発行] を選択します。 これらの手順を完了すると、Azure SQL Database CDC ソースをライブ ビューで視覚化できるようになります。
関連するコンテンツ
その他のコネクタ。