メインコンテンツまでスキップ
メインコンテンツまでスキップ

RDS Postgres ソースセットアップガイド

サポートされているPostgresバージョン

ClickPipesはPostgresバージョン12以降をサポートしています。

論理レプリケーションの有効化

以下の設定がすでに構成されている場合は、このセクションをスキップできます:

  • rds.logical_replication = 1
  • wal_sender_timeout = 0

これらの設定は、以前に別のデータレプリケーションツールを使用していた場合、通常は事前に構成されています。

構成されていない場合は、以下の手順に従ってください:

  1. 必要な設定を持つPostgresバージョンの新しいパラメータグループを作成します:
    • rds.logical_replicationを1に設定
    • wal_sender_timeoutを0に設定
  1. 新しいパラメータグループをRDS Postgresデータベースに適用します。
  1. 変更を適用するためにRDSインスタンスを再起動します。

データベースユーザーの設定

管理者ユーザーとしてRDS Postgresインスタンスに接続し、以下のコマンドを実行します:

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

  2. スキーマの権限を付与します。以下の例はpublicスキーマの権限を示しています。レプリケートしたい各スキーマに対してこれらのコマンドを繰り返します:

  3. レプリケーション権限を付与します:

  4. レプリケーション用の公開物を作成します:

ネットワークアクセスの設定

IPベースのアクセス制御

RDSインスタンスへのトラフィックを制限したい場合は、文書化された静的NAT IPをRDSセキュリティグループのInbound rulesに追加してください。

プライベートネットワークを通じてRDSインスタンスに接続するには、AWS PrivateLinkを使用できます。接続の設定については、ClickPipes用のAWS PrivateLinkセットアップガイドを参照してください。

RDS Proxyの回避策

RDS Proxyは論理レプリケーション接続をサポートしていません。RDSで動的IPアドレスを使用していて、DNS名やラムダを使用できない場合、いくつかの代替手段があります:

  1. cronジョブを使用して定期的にRDSエンドポイントのIPを解決し、変更があればNLBを更新します。
  2. RDSイベント通知をEventBridge/SNSとともに使用:AWS RDSイベント通知を使用して自動的に更新をトリガーします。
  3. 安定したEC2:ポーリングサービスまたはIPベースのプロキシとして機能するEC2インスタンスをデプロイします。
  4. TerraformやCloudFormationなどのツールを使用してIPアドレス管理を自動化します。

次は何ですか?

これで、ClickPipeを作成し、PostgresインスタンスからClickHouse Cloudにデータを取り込む準備が整いました。 Postgresインスタンスの設定時に使用した接続詳細をメモしておくことを忘れないでください。ClickPipeの作成プロセス中に必要になります。