PostgreSQL データベース CDC をソースとして Real-Time ハブに追加する

この記事では、PostgreSQL データベース変更データ キャプチャ (CDC) を Fabric Real-Time ハブのイベント ソースとして追加する方法について説明します。

Microsoft Fabric イベントストリーム用 PostgreSQL Database Change Data Capture (CDC) ソース コネクタを使用すると、PostgreSQL データベース内の現在のデータのスナップショットをキャプチャできます。 コネクタは、このデータに対する将来の行レベルの変更を監視し、記録します。

Prerequisites

• 共同作成者以上のアクセス許可を持つ、Fabric 容量ライセンス モード (または試用版ライセンス モード) のワークスペースへのアクセス。

• PostgreSQLデータベースへの登録済みユーザーアクセス。

• PostgreSQL データベースで CDC が有効になっています。

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

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

Azure Database for PostgreSQL で CDC を有効にする

Azure Database for PostgreSQL で CDC を有効にするには、デプロイの種類に基づいて次の手順に従います。

Azure Database for PostgreSQL 単一サーバー

1. Azure portal の [レプリケーション ] ページに移動します。

2. レプリケーション規則を 論理に変更します。

   

Azure Database for PostgreSQL - フレキシブル サーバー

1. Azure Portal の Azure Database for PostgreSQL フレキシブル サーバー ページで、ナビゲーション メニューの [サーバー パラメーター ] を選択します。

2. サーバーパラメータページで

   • wal_levelをlogicalに設定します。

   • max_worker_processesを少なくとも16 に更新します。

     

3. 変更点を保存し、サーバーを再起動します。

4. Azure Database for PostgreSQL フレキシブル サーバー インスタンスでパブリック ネットワーク トラフィックが許可されていることを確認します。

5. 次の SQL ステートメントを実行して、管理者ユーザーのレプリケーションアクセス許可を付与します。

   ALTER ROLE <admin user> WITH REPLICATION;
   

Azure Database for PostgreSQL CDC からイベントを取得する

Azure Database for PostgreSQL CDC から Real-Time ハブにイベントを取得するには、次のいずれかの方法があります。

• [データ ソース] ページの使用
• [Microsoft ソース] ページの使用

データ ソース ページ

1. Microsoft Fabric にサインインします。

2. ページの左下に [Power BI] が表示されている場合は、[Power BI] を選択してから [Fabric] を選択することで Fabric ワークロードに切り替えます。

   

3. 左側のナビゲーション バーで [リアルタイム] を選択します。

   

4. [リアルタイム ハブ] ページで、左側のナビゲーション メニューの [接続先] の下にある [+ データ ソース] を選択します。

   

   右上隅にある [+ データの追加] ボタンを選択して、Real-Time ハブ ページから [データソース] ページにアクセスすることもできます。

   

4. [データ ソース] ページで、上部にある Microsoft ソース カテゴリを選択し、Azure DB for PostgreSQL (CDC) タイルで [接続] を選択します。

   

   ソースとして PostgreSQL データベース CDC を追加するセクションの手順を使用します。

[Microsoft ソース] ページ

1. Real-Time ハブで、 Microsoft ソースを選択します。

2. [ ソース ] ドロップダウン リストで、[ PostgreSQL (CDC)] を選択します。

3. [サブスクリプション] で、PostgreSQL Database アカウントを持つリソース グループを持つ Azure サブスクリプションを選択します。

4. [リソース グループ] では、データベースを含むリソース グループを選択します。

5. [リージョン] では、データベースが存在する場所を選択します。

6. 次に、データベースの一覧で、Real-Time ハブに接続する PostgreSQL データベース CDC ソースの名前の上にマウスポインターを移動し、[ 接続 ] ボタンを選択するか、[ ...] を選択します。(省略記号) をクリックし、[ 接続 ] ボタンを選択します。

   

   接続情報を構成するには、「 ソースとして Azure Database for PostgreSQL CDC を追加 する」セクションの手順を使用します。

ソースとして Azure Database for PostgreSQL CDC を追加する

1. 接続ページで、新しい接続を選択します。

   

   Azure Database for PostgreSQL CDC ソースへの 既存の接続 がある場合は、[接続] ドロップダウン リストから接続を選択し、ポートとテーブルの構成に進むことができます。

   

2. 接続設定セクションで、次の情報を入力します。

   • サーバー： PostgreSQL データベースのサーバー アドレス (my-pgsql-server.postgres.database.azure.com など)。

   • データベース： データベース名 (my_database など)。

     

3. 下にスクロールし、[接続資格情報] セクションで、次の 手順に従います。

   1. 接続名 には、接続の名前を入力します。

   2. [認証の種類] で、[Basic] を選択します。

      Note

      現時点では、Fabric Eventstream は [基本] 認証のみサポートしています。

   3. データベースで、[ユーザー名] と [パスワード] を入力します。

   4. 「を選択し、に接続します。」

      

4. 次に、[接続] ページで、次の手順を実行します。

   1. テーブルの場合は、テーブル名を入力します。

   2. [ポート] で、ポート番号を入力するか、既定値の 5432 のままにします。

   3. [イベントストリーム名] にイベントストリーム名を入力します。 ウィザードは、選択した PostgreSQL データベース CDC をソースとして使用してイベントストリームを作成します。

   4. ストリーム名は、イベントストリームの名前に -stream を追加することで自動的に生成されます。 ウィザードが完了すると、[ すべてのデータ ストリーム ] ページにこのストリームが表示されます。

   5. ページの下部にある次へ を選択します。

      

5. [確認と接続] ページで概要を確認してから、[接続] を選択します。

   

データ ストリームの詳細を表示する

1. [ 確認と接続 ] ページで [ イベントストリームを開く] を選択すると、ウィザードによって、選択した PostgreSQL データベース CDC をソースとして作成したイベントストリームが開きます。 ウィザードを閉じるには、ページの下部にある [完了] を選択します。

   

2. Real-Time ハブのホーム ページの [最近のストリーミング データ] セクションにストリームが表示されます。 詳細な手順については、「Fabric リアルタイム ハブでのデータ ストリームの詳細の表示」を参照してください。

関連コンテンツ

データ ストリームの使用について詳しくは、次の記事を参照してください。

• データ ストリームの処理
• データ ストリームを分析する
• データ ストリームにアラートを設定する