:MySQL データソースの設定

制限事項

• DataWorks での MySQL からのリアルタイムデータ同期は、MySQL へのリアルタイムサブスクリプションを利用します。この機能は、MySQL5.x または8.x を実行する ApsaraDB RDS for MySQL インスタンスのみをサポートします。PolarDB-X 1.0 インスタンスを MySQL データソースとして設定しないでください。代わりに、直接 PolarDB-X 1.0 データソースとして設定できます。詳細については、「PolarDB-X 1.0 データソースの設定」をご参照ください。
• XA ROLLBACK はサポートされていません。XA PREPARE によって準備されたトランザクション内のデータについては、リアルタイム同期によってデータが送信先に書き込まれます。XA ROLLBACK が実行された場合、リアルタイム同期は準備されたデータをロールバックしません。XA ROLLBACK シナリオを処理するには、XA ROLLBACK の影響を受けるテーブルをリアルタイム同期タスクから手動で削除し、テーブルを再度追加してから、完全なデータ初期化と増分データ同期を実行する必要があります。
• 別の Alibaba Cloud アカウントに属する MySQL インスタンスをデータソースとして追加する場合、このデータソースを使用する同期タスクは Data Integration 専用リソースグループ でのみ実行できます。このデータソースへのアクセスに Data Integration 用共有リソースグループを使用することはできません。

操作手順

1. ホワイトリストの設定
   ご利用の Data Integration 専用リソースグループが配置されている VPC の CIDR ブロックを MySQL のホワイトリストに追加します。
   1. Data Integration 専用リソースグループの VPC 情報を表示して記録します。
      1. DataWorks コンソールにログインします。
      2. 左側のナビゲーションウィンドウで、[リソースグループ] をクリックします。
      3. [専用リソースグループ] タブで、対象のリソースグループを見つけ、[操作] 列の [情報を表示] をクリックします。
      4. 表示されたダイアログボックスで、[Elastic IP アドレス (EIP)] と [CIDR ブロック] をコピーしてデータベースのホワイトリストに追加します。
      5. [専用リソースグループ] タブで、対象のリソースグループを見つけ、[操作] 列の [ネットワーク設定] をクリックします。
      6. [VPC バインディング] タブで、[vSwitch の CIDR ブロック] を表示し、データベースのホワイトリストに追加します。
   2. 記録した Data Integration 専用リソースグループの Elastic IP アドレス (EIP) と CIDR ブロックを MySQL クラスターのホワイトリストに追加します。
2. アカウントの作成と権限の付与
   データベースのログインアカウントを準備する必要があります。このアカウントには、SELECT、REPLICATION SLAVE、REPLICATION CLIENT 権限が必要です。
   1. アカウントの作成
      詳細については、「MySQL アカウントの作成」をご参照ください。
   2. 権限の付与
      以下のステートメントを実行してアカウントに権限を付与するか、アカウントにSUPER 権限を付与します。以下のステートメントを実行する際は、'sync_account' を作成したアカウントに置き換えてください。

      -- 同期アカウントを作成し、パスワードを設定し、任意ホストからのデータベースへのログインを許可します。 パーセント記号 (%) は任意のホストを指定します。
      CREATE USER 'sync_account'@'%' IDENTIFIED BY 'password'; 
      -- データベースに対する SELECT、REPLICATION SLAVE、および REPLICATION CLIENT 権限を同期アカウントに付与します。
      GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'sync_account'@'%'; 

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

      説明 REPLICATION SLAVE 権限はグローバル権限であり、指定したデータベースの指定したテーブルに付与することはできません。
3. MySQL のバイナリログの有効化
   バイナリログが有効になっているかどうかを確認し、バイナリログのフォーマットをクエリします。

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

     show variables like "log_bin";

     ON が返された場合、バイナリログは有効です。

   • スタンバイデータベースを使用してデータを同期する場合は、以下のステートメントを実行してバイナリログが有効になっているかを確認することもできます。

     show variables like "log_slave_updates";

     ON が返された場合、スタンバイデータベースのバイナリログは有効です。

   異なる結果が返された場合は、MySQL の公式ドキュメントを参照してバイナリログを有効にしてください。
   以下のステートメントを実行して、バイナリログのフォーマットをクエリします。

   show variables like "binlog_format";

   返される結果について、次の表で説明します。

   • ROW が返された場合、バイナリログのフォーマットはROW です。
   • STATEMENT が返された場合、バイナリログのフォーマットはSTATEMENT です。
   • MIXED が返された場合、バイナリログのフォーマットはMIXED です。