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

論理レプリケーション

論理レプリケーションは、Lakebaseデータベースと別のPostgresデータベース間でレコードレベルの変更をストリームするネイティブなPostgresレプリケーションです。Lakebaseは、外部パブリッシャーからの変更を受け取るサブスクライバーとして、または外部サブスクライバーに変更を送信するパブリッシャーとして動作できます。

論理レプリケーションを使用して、既存の Postgres データベースを Lakebase に移行したり、Lakebase データベース間でレプリケートしたり、Lakebase から外部 Postgres データベースに変更をストリームしたりできます。

起動する​

単一のテーブルをエンドツーエンドで複製し、各要素がどのように連携するかを確認するには、クイックスタートから起動してください。完了まで数分かかり、外部データベースは必要ありません。

ユースケース​

ユースケース

内容

ガイド

PostgresデータベースをLakebaseに移行する

Lakebaseは外部のPostgresパブリッシャーをサブスクライブしてデータをコピーし、切り替えるまで現在の状態に保ちます。

Lakebase にデータをレプリケートする

Lakebase データベース間のレプリケーション

クロスリージョン読み取りまたはバージョンアップグレードのために、2 番目の Lakebase データベースを同期させます。

クイックスタート: Lakebase データベース間のレプリケート

変更を外部のPostgresにストリームします

Lakebase は変更を外部の Postgres サブスクライバーに公開します。

Lakebase からデータをレプリケートする

ユースケース

内容

ガイド

PostgresデータベースをLakebaseに移行する

Lakebaseは外部のPostgresパブリッシャーをサブスクライブしてデータをコピーし、切り替えるまで現在の状態に保ちます。

Lakebase にデータをレプリケートする

Lakebase データベース間のレプリケーション

クロスリージョン読み取りまたはバージョンアップグレードのために、2 番目の Lakebase データベースを同期させます。

クイックスタート: Lakebase データベース間のレプリケート

変更を外部のPostgresにストリームします

Lakebase は変更を外部の Postgres サブスクライバーに公開します。

Lakebase からデータをレプリケートする

論理レプリケーションの仕組み​

パブリッシャーは、送信する変更のテーブルセットであるパブリケーションを定義します。サブスクライバーは、パブリッシャーに接続し、既存のデータをコピーし、変更が発生するたびに各挿入、更新、および削除を適用するサブスクリプションを作成します。どのデータベースがどのデータベースに接続するかによって、ネットワークの方向が決まります:

2つの論理レプリケーション方向。サブスクライバーとしてのLakebase:外部のPostgresパブリッシャーがLakebaseに変更を送信し、Lakebaseはパブリッシャーにダイヤルアウトします。パブリッシャーとしてのLakebase:Lakebaseは変更をパブリッシュし、外部のPostgresサブスクライバーが変更を受け取るためにダイヤルインします。

論理レプリケーションとその他のデータ移動方法​

論理複製は、Postgresデータベース間でデータを移動します。代わりにPostgresの変更をレイクハウスに移動するには、 Lakebaseチェンジデータフィードを使用します。これは、変更をUnity CatalogマネージドDeltaテーブルに書き込みます。Lakebaseとの間でデータを移動する方法の完全な比較については、 「Lakebaseとの間でのデータの移動」を参照してください。

制限事項​

  • 論理レプリケーションはAWSとAzureで使用できます。
  • 論理レプリケーションはパブリックネットワーク経由で実行されます。どちらの方向でもプライベートLinkはサポートされていません。サブスクライバー接続は、アカウントのネットワークポリシーで許可されているインターネット宛先によって制御され、パブリッシャー接続はワークスペースのIPアクセスリストによって制御されます。
  • レプリケーションは読み取りレプリカではなく、プライマリコンピュートで実行されます。
  • 論理レプリケーションでは、スキーマではなくデータがコピーされます。レプリケーションを起動する前に、ターゲットテーブルを作成してください。その後のスキーマ変更は複製されません。
  • フォーリンテーブルは複製されません。

次のステップ​