CDC 用にセルフマネージド MySQL データベースを構成する

このページでは、セルフマネージド MySQL データベースから BigQuery や Cloud Storage などのサポートされている宛先にデータをストリーミングするように変更データ キャプチャ（CDC）を構成する方法について説明します。この手順は、MariaDB、Percona Server for MySQL、Alibaba Cloud PolarDB などのデータベースにも適用されます。

バイナリログの設定と保持期間を確認する

1. 次の MySQL コマンドを入力して、バイナリログが正しく設定されていることを確認します。

   SHOW GLOBAL VARIABLES LIKE '%binlog_format%';
   

2. binlog_format 変数の値が ROW に設定されていることを確認します。Datastream は、MIXED または STATEMENT のバイナリログ形式をサポートしていません。

3. 次の MySQL コマンドを入力して、バイナリログの行形式が FULL に設定されていることを確認します。

   SHOW GLOBAL VARIABLES LIKE 'binlog_row_image';
   

4. 次の MySQL コマンドを入力して、バイナリログのレプリカ更新オプションが ON に設定されていることを確認します。

   SHOW GLOBAL VARIABLES LIKE 'log_replica_updates';
   

   8.0.26 より前の MySQL バージョンの場合は、代わりに次のコマンドを入力します。

   SHOW GLOBAL VARIABLES LIKE 'log_slave_updates';
   

5. 次の MySQL コマンドを入力して、バイナリログの保持期間が 604800 秒（7 日）に設定されていることを確認します。

   SHOW GLOBAL VARIABLES LIKE 'binlog_expire_logs_seconds';
   

   MySQL バージョン 8.0.3 より前の場合は、代わりに次のコマンドを入力します。

   SHOW GLOBAL VARIABLES LIKE 'expire_logs_days';
   

   MySQL データベースが完全な行ベースのレプリケーションと 7 日間の保持期間に設定されていない場合は、次のようにバイナリログの構成を変更する必要があります。

   1. /etc/mysql/ ディレクトリに移動します。
   2. エディタを使用して、my.cnf ファイルを開きます。
   3. このファイルに次の行を追加します。

        [mysqld]
        log-bin=mysql-bin
        server-id=1
        binlog_format=ROW
        log-replica-updates=1
        # For MySQL versions earlier than 8.0.26, use log-slave-updates=true
        # instead.
        binlog_expire_logs_seconds=604800
        # For MySQL versions earlier than 8.0.3, use expire_logs_days=7 instead.
        max_allowed_packet=1G
        # '1G' is the recommended value.
        

   4. GTID ベースのレプリケーションの場合は、次の行も追加します。

        [mysqld]
        gtid_mode=ON
        enforce-gtid-consistency=ON
        

   5. 変更を my.cnf ファイルに保存してから、ファイルを閉じます。
   6. 変更が反映されるように、MySQL サーバーを再起動します。

Datastream ユーザーを作成する

1. DataStream ユーザーを作成するには、次の MySQL コマンドを入力します。

   CREATE USER 'datastream'@'%' IDENTIFIED BY 'YOUR_PASSWORD';
   GRANT REPLICATION SLAVE, SELECT, REPLICATION CLIENT ON *.* TO 'datastream'@'%';
   FLUSH PRIVILEGES;

次のステップ

• Datastream が MySQL ソースと連携する仕組みについて学習します。