イベントストリームに PostgreSQL データベース CDC ソースを追加（プレビュー）

[アーティクル]
06/06/2024

この記事では,PostgreSQL データベースの変更データキャプチャ（CDC）ソースをイベントストリームに追加する方法を説明します。

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

重要

Fabric イベントストリームの拡張機能は現在プレビュー段階です。

Note

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

前提条件

投稿者以上の権限を持つ Fabric プレミアムワークスペースへのアクセス権
PostgreSQLデータベースへの登録済みユーザーアクセス。
PostgreSQL データベースはパブリックにアクセスできる必要があり、ファイアウォールの内側やVirtual Network内で保護されてはなりません。
PostgreSQL データベースとテーブルで CDC が有効になっている。

PostgreSQL 用の Azure データベースがある場合は、次のセクションの手順に従って CDC を有効にします。詳細の情報については「論理レプリケーションと論理デコード - PostgreSQL 用 Azure データベース - フレキシブルサーバー」を参照してください。

その他の PostgreSQL データベースについては「PostgreSQL 用の Debezium コネクタ :: Debezium のドキュメント」を参照してください。

Note

1 つのイベントストリームでのソースと宛先の合計数は 11 個までです。

PostgreSQL 用の Azure データベースで CDC を有効にする

Azure Database for PostgreSQL フレキシブルサーバーで CDC を有効にするには、次の手順に従います。

Azure portal の Azure Database for PostgreSQL フレキシブルサーバーページで、ナビゲーションメニューの [サーバーパラメーター] を選択します。
サーバーパラメータページで
- wal_levelをlogicalに設定します。
- max_worker_processesを少なくとも16 に更新します。
変更点を保存し、サーバーを再起動します。
PostgreSQL Azure Database for PostgreSQL フレキシブルサーバーインスタンスでパブリックネットワークトラフィックが許可されていることを確認します。
次の SQL ステートメントを実行して、管理者ユーザーにレプリケーションアクセス許可権限を許可します。他のユーザーアカウントを使用して PostgreSQL DB を接続し CDC をフェッチする場合は、ユーザーがテーブル所有者であることを確認してください。
```
ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
```

PostgreSQL CDC の Azure データベースをソースとして追加する

[イベントストリーム]を選択して新しいイベントストリームを作成します。 [拡張機能 (プレビュー)] オプションが有効になっていることを確認します。
次の画面で、外部ソースの追加を選択します。

PostgreSQL CDC 用に Azure データベースを構成して接続する

データソースの選択画面で、Azure DB for PostgreSQL （CDC）を選択します.
接続ページで、新しい接続 を選択します。
接続設定セクションで、次の情報を入力します。
- サーバー： PostgreSQL データベースのサーバーアドレス (my-pgsql-server.postgres.database.azure.com など)。
- データベース：データベース名 (my_database など)。
下にスクロールし、[接続資格情報] セクションで、次の手順に従います。
1. 接続名 には、接続の名前を入力します。
2. [認証の種類] で、[Basic] を選択します。
  
  Note
  
  現在、ファブリックイベントストリームはBasic認証のみをサポートしています。
3. データベースで、[ユーザー名] と [パスワード] を入力します。
4. 接続を選択します。
次に、[接続] ページで、次の手順を実行します。
1. テーブルにテーブル名を入力します。
2. [ポート] で、ポート番号を入力するか、既定値の 5432 のままにします。
3. ページの下部にある次へを選択します。
[確認と作成] 画面で、概要を確認し、[追加] を選択します。