:MySQL からのデータ同期のためのデータソースの構成

制限事項

• MySQL からのデータのリアルタイム同期は、MySQL バイナリログへのリアルタイムサブスクリプションに基づいて実行されます。MySQL からのリアルタイムデータ同期は、MySQL 5.X または 8.X を実行する ApsaraDB RDS for MySQL データソースのみをサポートします。MySQL からのリアルタイムデータ同期は、MySQL を実行する PolarDB-X 1.0 データソースをサポートしていません。MySQL を実行する PolarDB-X 1.0 データソースからデータをリアルタイムで同期する場合は、「DRDS (PolarDB-X 1.0) データソース」を参照して、PolarDB-X 1.0 データソースを追加し、そのデータソースのリアルタイム同期ノードを構成できます。

• リアルタイム同期機能を使用して、XA ROLLBACK ステートメントが実行されたデータを同期することはできません。XA PREPARE ステートメントが実行されたトランザクションデータについては、リアルタイム同期機能を使用してデータを宛先に同期できます。後で XA ROLLBACK ステートメントがデータに対して実行された場合、データへのロールバックの変更は宛先に同期されません。同期するテーブルに XA ROLLBACK ステートメントが実行されたテーブルが含まれている場合は、XA ROLLBACK ステートメントが実行されたテーブルを削除し、削除したテーブルを再度追加して、ソースの完全データを初期化し、増分データを同期する必要があります。

• 現在のワークスペースとは異なる Alibaba Cloud アカウントに属する ApsaraDB RDS for MySQL インスタンスを MySQL データソースとして DataWorks に追加し、MySQL データソースのデータ同期ノードを構成する場合、Data Integration 専用のリソースグループのみを使用してノードを実行できます。共有リソースグループ for Data Integration を使用してノードを実行する場合、リソースグループは MySQL データソースのデータにアクセスできません。

手順

1. MySQL データベースのホワイトリストを構成します。

   専用リソースグループが存在する VPC の CIDR ブロックを MySQL データベースのホワイトリストに追加します。

   1. Data Integration 専用のリソースグループの Elastic IP アドレス (EIP) と CIDR ブロックを表示して記録します。

      1. DataWorks コンソールにログインします。

      2. 左側のナビゲーションペインで、[リソースグループ]をクリックします。

      3. [専用リソースグループ]タブで、Data Integration 専用のリソースグループを見つけ、[アクション] 列の [情報を表示]をクリックします。

      4. [専用リソースグループ] ダイアログボックスで、[eipaddress] パラメーターと [CIDR ブロック]パラメーターの値を表示して記録します。

      5. [専用リソースグループ]タブで、Data Integration 専用のリソースグループを見つけ、[アクション] 列の [ネットワーク設定]をクリックします。

      6. 表示されるページの [VPC バインディング]タブで、Data Integration 専用のリソースグループが関連付けられている [vswitch の CIDR ブロック]を表示して記録します。

   2. 専用リソースグループの EIP と CIDR ブロックを MySQL データベースのホワイトリストに追加します。

2. アカウントを作成し、アカウントに権限を付与します。

   MySQL データベースにログインするためのアカウントを作成する必要があります。SELECT、REPLICATION SLAVE、および REPLICATION CLIENT 権限をアカウントに付与する必要があります。

   1. アカウントを作成します。

      詳細については、「MySQL データベースにアクセスするためのアカウントの作成」をご参照ください。

   2. アカウントに権限を付与します。

      次のコマンドを実行して、アカウントに権限を付与できます。または、SUPER 権限をアカウントに付与することもできます。具体的なステートメントを実行するときは、Account for data synchronization を作成したアカウントに置き換えます。

      -- CREATE USER 'Account for data synchronization'@'%' IDENTIFIED BY 'Password'; // データの同期に使用するアカウントを作成し、パスワードを設定して、ホストからデータベースにアクセスできるようにします。% はホストを示します。
      GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'Account for data synchronization'@'%'; // SELECT、REPLICATION SLAVE、および REPLICATION CLIENT 権限をアカウントに付与します。

      *.* は、同期アカウントにすべてのデータベースのすべてのテーブルに対する上記の権限が付与されていることを示します。また、指定されたデータベースの指定されたテーブルに対する上記の権限を同期アカウントに付与することもできます。たとえば、user テーブルの test データベースに対する上記の権限をアカウントに付与するには、次のステートメントを実行します。GRANT SELECT, REPLICATION CLIENT ON test.user TO 'Account for data synchronization'@'%';。

      説明

      REPLICATION SLAVE 権限はグローバル権限です。指定されたデータベースの指定されたテーブルに対するこの権限を同期アカウントに付与することはできません。

3. MySQL データベースのバイナリロギング機能を有効にします。

   バイナリロギング機能が有効になっているかどうかを確認し、バイナリログの形式を照会するには、次の手順を実行します。

   • 次のステートメントを実行して、バイナリロギング機能が有効になっているかどうかを確認します。

     show variables like "log_bin";

     返された結果に ON が表示されている場合、バイナリロギング機能は有効になっています。

   • セカンダリデータベースを使用してデータを同期する場合は、次のステートメントを実行して、バイナリロギング機能が有効になっているかどうかを確認します。

     show variables like "log_slave_updates";

     返された結果に ON が表示されている場合、セカンダリデータベースのバイナリロギング機能は有効になっています。

   返された結果が上記の結果と異なる場合は、MySQL ドキュメントの説明に従ってバイナリロギング機能を有効にします。

   次のステートメントを実行して、バイナリログの形式を表示します。

   show variables like "binlog_format";

   返された結果:

   • ROW: バイナリログの形式は行です。

   • STATEMENT: バイナリログの形式はステートメントです。

   • MIXED: バイナリログの形式は混合です。