SeaTunnelを使用したOceanBaseデータの読み取りと同期

SeaTunnelのJDBC OceanBase Source ConnectorとJDBC OceanBase Sink Connectorを使用したデータ同期について説明します。JDBC OceanBase Source Connectorは、OceanBaseの単一テーブルデータのフル読み取りと書き込みをサポートします。詳細については、JDBC OceanBase Source Connectorを参照してください。JDBC OceanBase Sink Connectorは、OceanBaseの複数テーブルデータのフル読み取りと書き込みをサポートします。詳細については、JDBC OceanBase Sink Connectorを参照してください。

手順

以下の手順に従って、OceanBaseデータベースのMySQLテナント間でデータを同期します：

1. SeaTunnelユーザーを作成します。

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

2. config/plugin_configを設定します。

3. OceanBase JDBCドライバーをlibディレクトリにダウンロードします。詳細については、OceanBase Clientを参照してください。

4. SeaTunnelを設定します。

   設定ファイルconfig/ob_to_obを変更します：

   env {
   parallelism = 1
   job.mode = "BATCH"
   }
   
   source {
   # これは、SeaTunnelソースプラグインの機能をテストおよびデモンストレーションするための**サンプル**です。
   Jdbc {
       driver = com.oceanbase.jdbc.Driver
       url = "jdbc:oceanbase://e2e_oceanbase_mysql:2881/seatunnel?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&serverTimezone=UTC"
       user = "ユーザー名"
       password = "パスワード"
       query = "SELECT c_bit_1, c_bit_8 FROM source"
       compatible_mode = "mysql"
   }
   
   # SeaTunnelの設定方法やソースプラグインの完全なリストに関する詳細情報をご希望の場合は、
   # https://seatunnel.apache.org/docs/connector-v2/sink。
   }
   
   sink {
   Jdbc {
       driver = com.oceanbase.jdbc.Driver
       url = "jdbc:oceanbase://e2e_oceanbase_mysql:2881/seatunnel?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&serverTimezone=UTC"
       user = "ユーザー名"
       password = "パスワード"
       query = "insert into sink(c_bit_1, c_bit_8) values (?, ?);"
       compatible_mode = "mysql"
   }
   # SeaTunnelの設定方法やシンクプラグインの完全なリストに関する詳細情報をご希望の場合は、
   # https://seatunnel.apache.org/docs/2.3.4/connector-v2/source/MySQL-CDC/。
   }
   

5. SeaTunnelを起動します。

   以下のコマンドを実行して、SeaTunnelを起動します：

   ./bin/seatunnel.sh --config ./config/ob_to_ob -e local