Datastream を使用して、ソース PostgreSQL データベースからサポートされている宛先（BigQuery や Cloud Storage など）に継続的な変更をストリーミングできます。データベース アクティビティをキャプチャするために、Datastream は論理デコードを使用して、パブリケーション スロットとレプリケーション スロットを介して write-ahead log（WAL）ファイルから変更を読み取ります。詳細については、PostgreSQL データベースの WAL ファイルを操作するをご覧ください。
パブリケーションとレプリケーション スロット
PostgreSQL ソースを構成する場合は、パブリケーションとレプリケーション スロットを作成する必要があります。
パブリケーションは、テーブルまたはテーブルのグループから生成された、論理レプリケーションを使用して複製する一連の変更です。
レプリケーション スロットは、WAL ログファイルに保存されている一連の変更が正しい順序で宛先に確実に複製されるようにする PostgreSQL の機能です。
各レプリケーション スロットは、単一のデータベースから一連の変更をストリーミングします。各パブリケーションは 1 つのデータベースにのみ存在します。つまり、データベースごとに 1 つ以上のストリームを作成し、ストリームごとに 1 つのレプリケーション スロットを作成する必要があります。また、明確にするために記すと、パブリケーション名をストリームで選択したテーブルと一致させることをおすすめします。
詳細については、PostgreSQL ドキュメントのパブリケーション スロットとレプリケーション スロットをご覧ください。
サポートされるデータベース
Datastream は、以下の種類の PostgreSQL データベースに対応しています。
- AlloyDB for PostgreSQL
- AlloyDB Omni
- Amazon Aurora PostgreSQL
- Amazon RDS for PostgreSQL
- Cloud SQL for PostgreSQL
- セルフマネージド PostgreSQL（オンプレミスまたはクラウドホスト型）
Datastream は、PostgreSQL バージョン 16 以降の PostgreSQL リードレプリカ インスタンスからのレプリケーションもサポートしています。詳細については、リードレプリカからのレプリケーションをご覧ください。
次のステップ
- Datastream と連携するように AlloyDB for PostgreSQL データベースを構成する方法について学習します。
- Datastream と連携するように AlloyDB Omni を構成する方法について学習します。
- Datastream と連携するように Amazon Aurora PostgreSQL データベースを構成する方法について学習します。
- Datastream と連携するように Amazon RDS for PostgreSQL データベースを構成する方法について学習します。
- Datastream と連携するように Cloud SQL for PostgreSQL データベースを構成する方法について学習します。
- Datastream と連携するようにセルフマネージド PostgreSQL データベースを構成する方法について学習します。