論理レプリケーション
論理レプリケーションは、Lakebaseデータベースと別のPostgresデータベース間でレコードレベルの変更をストリームするネイティブなPostgresレプリケーションです。Lakebaseは、外部パブリッシャーからの変更を受け取るサブスクライバーとして、または外部サブスクライバーに変更を送信するパブリッシャーとして動作できます。
論理レプリケーションを使用して、既存の Postgres データベースを Lakebase に移行したり、Lakebase データベース間でレプリケートしたり、Lakebase から外部 Postgres データベースに変更をストリームしたりできます。
起動する
単一のテーブルをエンドツーエンドで複製し、各要素がどのように連携するかを確認するには、クイックスタートから起動してください。完了まで数分かかり、外部データベースは必要ありません。
- クイックスタート :2 つの Lakebase データベース間で 1 つのテーブルをレプリケートします。「クイックスタート:Lakebase データベース間のレプリケーション」を参照してください。
ユースケース
ユースケース | 内容 | ガイド |
|---|---|---|
PostgresデータベースをLakebaseに移行する | Lakebaseは外部のPostgresパブリッシャーをサブスクライブしてデータをコピーし、切り替えるまで現在の状態に保ちます。 | |
Lakebase データベース間のレプリケーション | クロスリージョン読み取りまたはバージョンアップグレードのために、2 番目の Lakebase データベースを同期させます。 | |
変更を外部のPostgresにストリームします | Lakebase は変更を外部の Postgres サブスクライバーに公開します。 |
論理レプリケーションの仕組み
パブリッシャーは、送信する変更のテーブルセットであるパブリケーションを定義します。サブスクライバーは、パブリッシャーに接続し、既存のデータをコピーし、変更が発生するたびに各挿入、更新、および削除を適用するサブスクリプションを作成します。どのデータベースがどのデータベースに接続するかによって、ネットワークの方向が決まります:

論理レプリケーションとその他のデータ移動方法
論理複製は、Postgresデータベース間でデータを移動します。代わりにPostgresの変更をレイクハウスに移動するには、 Lakebaseチェンジデータフィードを使用します。これは、変更をUnity CatalogマネージドDeltaテーブルに書き込みます。Lakebaseとの間でデータを移動する方法の完全な比較については、 「Lakebaseとの間でのデータの移動」を参照してください。
制限事項
- 論理レプリケーションはAWSとAzureで使用できます。
- 論理レプリケーションはパブリックネットワーク経由で実行されます。どちらの方向でもプライベートLinkはサポートされていません。サブスクライバー接続は、アカウントのネットワークポリシーで許可されているインターネット宛先によって制御され、パブリッシャー接続はワークスペースのIPアクセスリストによって制御されます。
- レプリケーションは読み取りレプリカではなく、プライマリコンピュートで実行されます。
- 論理レプリケーションでは、スキーマではなくデータがコピーされます。レプリケーションを起動する前に、ターゲットテーブルを作成してください。その後のスキーマ変更は複製されません。
- フォーリンテーブルは複製されません。
次のステップ
- クイックスタート : 2つの Lakebase データベース間で1つのテーブルをレプリケートします。クイックスタート:Lakebase データベース間のレプリケーションを参照してください。
- Lakebase に移行 : 既存の Postgres データベースを Lakebase にレプリケートします。「Lakebase へのデータのレプリケーション」を参照してください。
- メソッドの比較 : Lakebase からデータを移動する正しい方法を選択します。「Lakebase との間のデータの移動」を参照してください。