: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 データソースを追加し、そのデータソースのリアルタイム同期ノードを設定できます。
• リアルタイム同期機能を使用して、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 権限をアカウントに付与することもできます。具体的なステートメントを実行する際には、データ同期用のアカウントを作成したアカウントに置き換えてください。

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

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

      説明 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: バイナリログの形式は混合です。