次の方法で共有


PostgreSQL データベース CDC をソースとしてリアルタイム ハブに追加する

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

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

前提条件

Note

複数テーブルの CDC はサポートされていません。

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

PostgreSQL用のAzureデータベース で CDC を有効にするには、展開の種類に基づいて次の手順に従います。

Azure Database for PostgreSQL - 単一サーバー

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

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

    単一サーバー展開で CDC を有効にするスクリーンショット。

PostgreSQLフレキシブル サーバー用 Azure データベース

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

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

    • wal_levellogicalに設定します。

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

      柔軟なサーバー展開のために CDC を有効にするスクリーンショット。

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

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

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

    ALTER ROLE <admin user> WITH REPLICATION;
    

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

次のいずれかの方法で、Azure Database for PostgreSQL CDC からリアルタイム ハブにイベントを取得できます。

データ ソース ページ

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

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

  3. [リアルタイム ハブ] ページで、左側のナビゲーション メニューの [接続先] の下にある [+ データ ソース] を選択します。 また、右上にある [+ データ ソースに接続] ボタンを選択して、[すべてのデータ ストリーム] ページまたは [マイ データ ストリーム] ページから [データ ソース] ページにアクセスすることもできます。

    [データ ソースに接続] エクスペリエンスを起動する方法を示すスクリーンショット。

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

    [データ ソース] ページでソースの種類として Azure Database (DB) for PostgreSQL (CDC) が選択されていることを示すスクリーンショット。

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

[Microsoft ソース] ページ

  1. リアルタイム ハブで、[Microsoft ソース] を選択します。

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

  3. [サブスクリプション] で、使用する PostgreSQL データベース アカウントがあるリソース グループを含む Azure サブスクリプションを選択します。

  4. [リソース グループ] では、お使いの IoT ハブのあるリソース グループを選択します。

  5. [リージョン] では、IoT ハブのある場所を選択します。

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

    Azure PostgreSQL CDC を表示するフィルターと接続ボタンがある [Microsoft ソース] ページを示すスクリーンショット。

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

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

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

    新しい接続リンクが強調表示された Azure PostgreSQL データベースの接続ページを示すスクリーンショット。

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

    既存の接続が選択されている [接続] ページを示すスクリーンショット。

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

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

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

      Azure PostgreSQL データベース コネクタの [接続設定] セクションを示すスクリーンショット。

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

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

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

      Note

      現在、ファブリック イベント ストリームはBasic認証のみをサポートしています。

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

    4. 接続を選択します。

      Azure PostgreSQL データベース コネクタの [接続資格情報] セクションを示すスクリーンショット。

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

    1. テーブルにテーブル名を入力します。

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

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

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

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

      Azure PostgreSQL データベース コネクタの入力された [接続] ページを示すスクリーンショット。

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

    Azure PostgreSQL データベース コネクタ用に入力された [確認と接続] ページを示すスクリーンショット。

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

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

    [確認および接続] の成功ページを示すスクリーンショット。

  2. リアルタイム ハブで、[マイ データ ストリーム] を選択します。 新しいデータ ストリームを表示するには、ページを最新の情報に更新します。

    PostgreSQL Database CDC ソースに基づくストリームを含む、リアルタイム ハブの [マイ データ ストリーム] ページを示すスクリーンショット。

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