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

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

ClickPipes は Aurora PostgreSQL 互換エディションのバージョン 12 以降に対応しています。

論理レプリケーションを有効にする

Aurora インスタンスですでに次の設定が行われている場合は、このセクションはスキップしてかまいません。

rds.logical_replication = 1
wal_sender_timeout = 0

これらの設定は、以前に別のデータレプリケーションツールを使用していた場合には、あらかじめ設定されていることが一般的です。

postgres=> SHOW rds.logical_replication ;
 rds.logical_replication
-------------------------
 on
(1 row)

postgres=> SHOW wal_sender_timeout ;
 wal_sender_timeout
--------------------
 0
(1 row)

まだ設定していない場合は、次の手順に従ってください。

使用している Aurora PostgreSQL のバージョン用に、必要な設定を含む新しいパラメータグループを作成します：
- rds.logical_replication を 1 に設定します
- wal_sender_timeout を 0 に設定します

新しいパラメータグループを Aurora PostgreSQL クラスターに適用します

Aurora クラスターを再起動して変更を反映します

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

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

ClickPipes 用の専用ユーザーを作成します：
```
CREATE USER clickpipes_user PASSWORD 'some-password';
```
スキーマの権限を付与します。次の例では、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;
```
レプリケーション権限を付与します：
```
GRANT rds_replication TO clickpipes_user;
```
レプリケーション用のパブリケーションを作成します：
```
CREATE PUBLICATION clickpipes_publication FOR ALL TABLES;
```

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

IP ベースのアクセス制御

Aurora クラスターへのトラフィックを制限したい場合は、ドキュメントに記載されている固定 NAT IP を Aurora セキュリティグループの Inbound rules に追加してください。

AWS PrivateLink を使用したプライベートアクセス

プライベートネットワーク経由で Aurora クラスターに接続するには、AWS PrivateLink を使用できます。接続を設定するには、ClickPipes 用の AWS PrivateLink セットアップガイドに従ってください。

Aurora 固有の考慮事項

Aurora PostgreSQL と ClickPipes を連携させる際は、次の点を考慮してください。

接続エンドポイント: 常に Aurora クラスターの writer エンドポイントに接続してください。論理レプリケーションでは、レプリケーションスロットを作成するために書き込みアクセスが必要であり、プライマリインスタンスに接続しなければなりません。
フェイルオーバー処理: フェイルオーバーが発生すると、Aurora は自動的にリーダーを新しい writer に昇格させます。ClickPipes は切断を検知し、writer エンドポイントへの再接続を試みます。このエンドポイントは新しいプライマリインスタンスを指すようになります。
グローバルデータベース: Aurora Global Database を使用している場合は、プライマリリージョンの writer エンドポイントに接続する必要があります。リージョン間レプリケーションが、すでにリージョン間のデータ移動を処理しているためです。
ストレージに関する考慮事項: Aurora のストレージレイヤーはクラスター内のすべてのインスタンスで共有されており、標準的な RDS と比較して、論理レプリケーションのパフォーマンスが向上する可能性があります。

動的なクラスターエンドポイントへの対応

Aurora では、適切なインスタンスに自動的にルーティングされる安定したエンドポイントが提供されていますが、一貫した接続性を確保するために、次のような追加のアプローチがあります。

高可用性構成の場合は、アプリケーションを Aurora の writer エンドポイントを使用するように構成してください。これは自動的に現在のプライマリインスタンスを指します。
リージョン間レプリケーションを使用している場合は、レイテンシーを低減し、耐障害性を向上させるために、リージョンごとに個別の ClickPipes を設定することを検討してください。

次のステップ

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

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

論理レプリケーションを有効にする​

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

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

IP ベースのアクセス制御​

AWS PrivateLink を使用したプライベートアクセス​

Aurora 固有の考慮事項​

動的なクラスターエンドポイントへの対応​

次のステップ​