次の方法で共有


リアルタイム ハブでソースとして PostgreSQL データベース CDC を追加する (プレビュー)

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

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

Note

リアルタイム ハブは現在プレビュー段階です。

前提条件

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;
    

起動ソース エクスペリエンスの追加

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

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

  3. [リアルタイム ハブ] ページで、ページの右上隅にある [+ ソースの追加] を選択します。

    Microsoft Fabric で Real-Time Hub を起動する方法を示すスクリーンショット。

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

Microsoft ソース ページ

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

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

  3. [サブスクリプション] で、お使いの Cosmos DB アカウントを持つリソース グループを含む Azure サブスクリプションを選択します。

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

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

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

    Azure MySQL CDC と接続ボタンを示すフィルターを含む [Microsoft ソース] ページを示すスクリーンショット。

    接続情報を構成するには、「ソースとして Azure MySQL DB CDC を追加する」セクションの手順を使用します。 ソースの追加ウィザードで、ソースの種類として Azure MySQL DB CDC を選択する最初の手順をスキップします。

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

  1. データ ソースの選択画面で、Azure DB for PostgreSQL (CDC) を選択します.

    PostgreSQL DB (CDC) を選択しているスクリーンショット。

  2. [接続] ページで、 [リソースに移動] を選択してAzure PostgreSQL データベースに移動します。 [概要] ペインで、[サーバー名] の値を記録しておきます。 または という形式で指定しますmyazurepostgresqlserver.postgres.database.azure.com

    「リソースに移動」リンクが強調表示された「接続」ページを示すスクリーンショット。

  3. データ 接続ページで、新しい接続を選択します

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

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

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

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

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

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

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

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

      Note

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

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

    4. 接続を選択します。

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

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

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

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

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

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

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

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

  7. 表示された [確認と作成] タブで概要を確認し、[ソースを作成] を選びます。

    Azure PostgreSQL データベース コネクタの [確認と作成] ページを示すスクリーンショット。

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

  1. [確認して作成] ページで、[イベント ストリームを開く] を選択すると、ウィザードは、選択したサンプル データ ソースを使用して作成されたイベント ストリームを開きます。 ページの下部の [閉じる] をクリックしてウィザードを終了します。

    [確認と作成] タブを示すスクリーンショット。

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

    PostgreSQL データベース CDC ソースに基づくストリームを含む [すべてのデータ ストリーム] ページを示すスクリーンショット。

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