PolarDB の単一テーブルのデータをリアルタイムで同期する前に、このトピックの操作を実行して、データソースのネットワーク環境、IP アドレスホワイトリスト、および権限を設定する必要があります。
前提条件
データソースを設定する前に、次の操作が実行されていることを確認してください。
- データソースを準備する: PolarDB for MySQL クラスタと同期先が準備されています。同期先は、MaxCompute、Hologres、Elasticsearch、DataHub、または Kafka にすることができます。 このトピックでは、PolarDB for MySQL クラスタをソースとして使用します。
- リソースを計画および準備する: データ統合専用のリソースグループが購入および設定されています。詳細については、「リソースの計画と設定」をご参照ください。
- ネットワーク環境を評価および計画する: データ統合を実行する前に、ビジネス要件に基づいてネットワーク接続方法を選択し、その方法を使用してデータソースをデータ統合専用のリソースグループに接続する必要があります。データソースとデータ統合専用のリソースグループが接続された後、このトピックで説明されている操作を参照して、vSwitch やホワイトリストなどのアクセス設定を行うことができます。
- データソースとデータ統合専用のリソースグループが同じリージョンおよび仮想プライベートクラウド (VPC) に存在する場合、それらは自動的に接続されます。
- データソースとデータ統合専用のリソースグループが異なるネットワーク環境に存在する場合は、VPN ゲートウェイなどの方法を使用して、データソースとリソースグループを接続する必要があります。
背景情報
データソース間でデータを同期する前に、データソースとデータ統合専用のリソースグループが接続されていることを確認してください。さらに、アカウントを作成し、そのアカウントにデータソースへのアクセスを承認する必要があります。
- データソースのホワイトリストを設定するデータソースとデータ統合専用のリソースグループが同じ VPC に存在する場合は、データ統合専用のリソースグループの CIDR ブロックをデータソースのホワイトリストに追加する必要があります。これにより、データ統合専用のリソースグループを使用してデータソースにアクセスできるようになります。

- アカウントを作成し、アカウントを承認する
データ同期プロセス中に、データソースへのアクセス、ソースからのデータの読み取り、および同期先へのデータの書き込みに使用できるアカウントを作成する必要があります。
- バイナリロギング機能を有効にする
ソースが PolarDB for MySQL クラスタの場合、クラスタのバイナリロギング機能を有効にする必要があります。Alibaba Cloud PolarDB for MySQL は MySQL と完全に互換性があり、高レベルの物理ログを使用してバイナリログを置き換えます。PolarDB と MySQL エコシステム間の統合を容易にするために、PolarDB クラスタのバイナリロギング機能を有効にすることができます。
制限事項
- データ同期ソリューションでは、PolarDB for MySQL クラスタのみをソースとして使用できます。他のタイプの PolarDB データソースはサポートされていません。このトピックでは、PolarDB は PolarDB for MySQL データソースを示します。
- PolarDB for MySQL クラスタのプライマリノードに格納されているデータのみを同期できます。
- リアルタイム同期機能を使用して、XA ROLLBACK ステートメントが実行されたデータを同期することはできません。XA PREPARE ステートメントが実行されたトランザクションデータについては、リアルタイム同期機能を使用してデータを同期先に同期できます。後で XA ROLLBACK ステートメントがデータに対して実行された場合、データへのロールバックの変更は同期先に同期されません。同期するテーブルに XA ROLLBACK ステートメントが実行されたテーブルが含まれている場合は、XA ROLLBACK ステートメントが実行されたテーブルを削除し、削除されたテーブルを再度追加して、ソースの全データを初期化し、増分データを同期する必要があります。
手順
- PolarDB for MySQL クラスタのホワイトリストを設定します。データ統合専用のリソースグループが存在する VPC の CIDR ブロックを PolarDB for MySQL クラスタのホワイトリストに追加するには、次の手順を実行します。
- データ統合専用のData Integration 専用リソースグループの Elastic IP アドレス (EIP) と CIDR ブロックを表示および記録します。リソースグループの Elastic IP アドレス (EIP) と CIDR ブロックを表示して記録します。
- DataWorksコンソール にログオンします。
- 左側のナビゲーションペインで、[リソースグループ] をクリックします。
- [専用リソースグループ] タブで、Data Integration の専用リソースグループを見つけ、[アクション] 列の [情報表示] をクリックします。
- [eipaddress] パラメーターと [CIDRブロック] パラメーターの値を [専用リソースグループ] ダイアログボックスで表示し、記録します。
- [専用リソースグループ] タブで、Data Integration の専用リソースグループを見つけ、[アクション] 列の [ネットワーク設定] をクリックします。
- 表示されるページの [VPCバインディング] タブで、Data Integration の専用リソースグループが関連付けられている [vswitch の CIDRブロック] を表示し、記録します。
- 前の手順で記録した EIP と CIDR ブロックを PolarDB for MySQL クラスタのホワイトリストに追加します。
詳細については、「IP ホワイトリストの設定」をご参照ください。
- データ統合専用のData Integration 専用リソースグループの Elastic IP アドレス (EIP) と CIDR ブロックを表示および記録します。
- アカウントを作成し、必要な権限をアカウントに付与します。PolarDB for MySQL クラスタのデータベースにログインするためのアカウントを作成する必要があります。
SELECT、REPLICATION SLAVE、および REPLICATION CLIENT権限をアカウントに付与する必要があります。- アカウントを作成します。詳細については、「データベースアカウントの作成」をご参照ください。
- 必要な権限をアカウントに付与します。次のコマンドを実行して必要な権限をアカウントに付与するか、
SUPERロールをアカウントに直接割り当てることができます。-- CREATE USER 'Account for data synchronization'@'%' IDENTIFIED BY 'Account for data synchronization'; GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'Account for data synchronization'@'%';
- アカウントを作成します。
- PolarDB for MySQL クラスタのバイナリロギング機能を有効にします。詳細については、「バイナリロギングの有効化」をご参照ください。
次の手順
データソースが設定され、ソース、同期先、およびデータ統合専用のリソースグループが接続されたら、承認済みアカウントを使用してデータソースにアクセスできます。ソースと同期先の両方を DataWorks に追加し、データ同期ソリューションの作成時にそれらを関連付けることができます。データソースを追加する方法の詳細については、「データソースの追加」をご参照ください。