AlloyDB Postgres ソースの設定ガイド

ClickPipes を使用して AlloyDB インスタンスから ClickHouse Cloud にデータを連携するには、インスタンスで論理レプリケーションが設定されている必要があります。これは AlloyDB Version 14 以降でサポートされています。

AlloyDB インスタンスで論理レプリケーションが有効になっているかを確認するには、プライマリインスタンスに対して次のクエリを実行します。

SHOW  wal_level;

結果が logical の場合は、論理レプリケーションはすでに有効になっているため、次の手順に進んでください。結果が replica の場合は、プライマリ インスタンスで alloydb.enable_pglogical フラグと alloydb.logical_decoding フラグを on に設定する必要があります。

これらのフラグを有効にするには、次の手順を実行します。

1. Google Cloud Console で AlloyDB の Clusters ページに移動します。プライマリ インスタンスの Actions メニューから Edit をクリックします。

   

2. 下にスクロールして Advanced configuration options セクションを展開します。Flags で Add a database flag をクリックします。

   • allowdb.enable_pglogical フラグを追加し、値を on に設定します
   • alloydb.logical_decoding フラグを追加し、値を on に設定します

   

3. Update instance をクリックして構成変更を保存します。この操作により、プライマリ インスタンスが再起動される点に注意してください。

4. インスタンスのステータスが Updating から Ready に変わったら、次のクエリをプライマリ インスタンスに対して実行し、論理レプリケーションが有効になっていることを確認します。

   SHOW  wal_level;

   結果は logical になるはずです。

   

管理者ユーザーとして AlloyDB インスタンスに接続し、次のコマンドを実行します。

1. ClickPipes 専用のユーザーを作成します。

   CREATE USER clickpipes_user PASSWORD 'some-password';

2. 前の手順で作成したユーザーに、スキーマレベルの読み取り専用アクセス権を付与します。次の例は public スキーマに対する権限を示しています。レプリケーションするテーブルを含む各スキーマに対して、これらのコマンドを繰り返してください。

   GRANT USAGE ON SCHEMA "public" TO clickpipes_user;
   GRANT SELECT ON ALL TABLES IN SCHEMA "public" TO clickpipes_user;
   ALTER DEFAULT PRIVILEGES IN SCHEMA "public" GRANT SELECT ON TABLES TO clickpipes_user;

3. ユーザーにレプリケーション権限を付与します。

   ALTER USER clickpipes_user WITH REPLICATION;

4. レプリケーションしたいテーブルを含む publication を作成します。パフォーマンスのオーバーヘッドを避けるため、publication には必要なテーブルだけを含めることを強く推奨します。

• 特定のテーブルに対する publication を作成するには:

  CREATE PUBLICATION clickpipes FOR TABLE table_to_replicate, table_to_replicate2;

  • 特定のスキーマ内のすべてのテーブルに対する publication を作成するには:

    CREATE PUBLICATION clickpipes FOR TABLES IN SCHEMA "public";

clickpipes publication は、変更イベントが ClickPipes にストリーミングされる対象テーブルの集合を定義します。すべてのテーブルをレプリケーションするのでない限り、FOR ALL TABLES の使用は推奨しません。不要なテーブルを含めると、Postgres から ClickPipes への WAL トラフィックが増加し、レプリケーション全体の効率が低下するためです。

次に、ClickPipes が AlloyDB インスタンスに接続する方法を選択します。

これで、ClickPipe を作成して、Postgres インスタンスから ClickHouse Cloud へのデータ取り込みを開始できます。 ClickPipe の作成時に必要になるため、Postgres インスタンスのセットアップ時に使用した接続情報は必ず控えておいてください。