Canalを使用したデータの同期|OceanBase Cloud|ドキュメント|OceanBaseマニュアル

OceanBase CloudのBinlogサービスを有効にします。 Binlogサービスを有効にするパス：インスタンスリスト -> テナント管理 -> Binlogサービスで、「開始」をクリックします。詳細については、Binlogサービスの開始をご参照ください。

データ同期用のユーザーを作成します。

 CREATE USER 'ユーザー名'@'%' IDENTIFIED BY 'パスワード';
 GRANT SELECT ON *.* TO 'ユーザー名';

Canal Serverを設定します。 conf/example/instance.propertiesファイルを変更し、OceanBase Cloud MySQLのアドレス、ポート、ユーザー名、パスワード、および監視対象のデータベースとテーブルを設定します。Canalサービスを起動し、そのログを監視して正常に動作していることを確認します。サンプル設定ファイルは以下のとおりです：

vi conf/example/instance.properties

 # OceanBase Cloud MySQLデータソースの接続情報を設定します
 canal.instance.master.address=送信元OceanBase Cloud MySQLサーバーのアドレス:ポート
 canal.instance.dbUsername=ユーザー名
 canal.instance.dbPassword=パスワード

 # その他のパラメータはデフォルトのままにします

Canal Serverを起動します。

cd /Canal_Home/canal && sh bin/startup.sh

ログファイルを確認し、Canal Serverが正常に起動したことを確認します：

tail -f logs/canal/canal.log

Canal Adapterを設定します。 Canal Adapterの設定ディレクトリconfに移動し、application.yml設定ファイルを編集して、rdb Adapterのプロパティを設定します：

mode: tcp #tcp kafka rocketMQ rabbitMQ
dataSourceKey: defaultDS
destination: example
groupId: g1
outerAdapters:
- name: rdb
    key: mysql1
    properties:
    jdbc.driverClassName: com.mysql.cj.jdbc.Driver
    jdbc.url: jdbc:mysql://宛先MySQLアドレス:ポート/宛先データベース名?useUnicode=true&characterEncoding=UTF-8&useSSL=false
    jdbc.username: 宛先データベースのユーザー名
    jdbc.password: 宛先データベースのパスワード

Canal Adapterはさまざまなタイプのデータストレージシステムをサポートしており、各タイプに対応するAdapterがあります。RDB AdapterはCanal Adapterの一部であり、リレーショナルデータベース間のデータ同期に特化しています。RDB（Relational Database）マッピングファイルの例は以下のとおりです：

cat conf/rdb/mytest_user.yml


dataSourceKey: defaultDS
destination: example
groupId: g1
outerAdapterKey: mysql1
concurrent: true
dbMapping:
database: 送信元データベース名
table: 送信元テーブル名
targetTable: ターゲットデータベース名.ターゲットテーブル名
targetPk:
    id: 主キー列
mapAll: true

Canal Adapterを起動します。

cd /Canal_Home/adapter && sh bin/startup.sh

ログファイルを確認し、Canal Adapterが正常に起動したことを確認します：

tail -f logs/adapter/adapter.log

データ同期を検証します。ターゲットデータベースのテーブルを確認し、ソースデータが正常に同期されたかどうかを検証します。

Canalを使用したデータの同期

背景

前提条件

操作手順