RDS Postgres ソースセットアップガイド
サポートされているPostgresバージョン
ClickPipesはPostgresバージョン12以降をサポートしています。
論理レプリケーションの有効化
以下の設定がすでに構成されている場合は、このセクションをスキップできます:
rds.logical_replication = 1
wal_sender_timeout = 0
これらの設定は、以前に別のデータレプリケーションツールを使用していた場合、通常は事前に構成されています。
構成されていない場合は、以下の手順に従ってください:
- 必要な設定を持つPostgresバージョンの新しいパラメータグループを作成します:
rds.logical_replication
を1に設定wal_sender_timeout
を0に設定



- 新しいパラメータグループをRDS Postgresデータベースに適用します。

- 変更を適用するためにRDSインスタンスを再起動します。

データベースユーザーの設定
管理者ユーザーとしてRDS Postgresインスタンスに接続し、以下のコマンドを実行します:
-
ClickPipes用の専用ユーザーを作成します:
-
スキーマの権限を付与します。以下の例は
public
スキーマの権限を示しています。レプリケートしたい各スキーマに対してこれらのコマンドを繰り返します: -
レプリケーション権限を付与します:
-
レプリケーション用の公開物を作成します:
ネットワークアクセスの設定
IPベースのアクセス制御
RDSインスタンスへのトラフィックを制限したい場合は、文書化された静的NAT IPをRDSセキュリティグループのInbound rules
に追加してください。


AWS PrivateLinkによるプライベートアクセス
プライベートネットワークを通じてRDSインスタンスに接続するには、AWS PrivateLinkを使用できます。接続の設定については、ClickPipes用のAWS PrivateLinkセットアップガイドを参照してください。
RDS Proxyの回避策
RDS Proxyは論理レプリケーション接続をサポートしていません。RDSで動的IPアドレスを使用していて、DNS名やラムダを使用できない場合、いくつかの代替手段があります:
- cronジョブを使用して定期的にRDSエンドポイントのIPを解決し、変更があればNLBを更新します。
- RDSイベント通知をEventBridge/SNSとともに使用:AWS RDSイベント通知を使用して自動的に更新をトリガーします。
- 安定したEC2:ポーリングサービスまたはIPベースのプロキシとして機能するEC2インスタンスをデプロイします。
- TerraformやCloudFormationなどのツールを使用してIPアドレス管理を自動化します。
次は何ですか?
これで、ClickPipeを作成し、PostgresインスタンスからClickHouse Cloudにデータを取り込む準備が整いました。 Postgresインスタンスの設定時に使用した接続詳細をメモしておくことを忘れないでください。ClickPipeの作成プロセス中に必要になります。