AnalyticDB:zero-ETLを使用したデータの同期

AnalyticDB for MySQLのサービスにリンクされたロールを作成する

1. Resource Access Management (RAM) コンソールにログインします。 左側のナビゲーションウィンドウで、[アイデンティティ]> [ロール] を選択します。

2. AliyunServiceRoleForAnalyticDBForMySQLという名前のサービスにリンクされたロールがロールリストに存在するかどうかを確認します。 サービスにリンクされたロールが存在しない場合は、ロールを作成する必要があります。

3. [ロール] ページの左上隅にある [ロールの作成] をクリックします。

4. [ロールタイプの選択] ステップで、[Alibaba Cloud Service] を選択し、[次へ] をクリックします。

5. [ロールの設定] ステップで、[ロールタイプ] パラメーターに [サービスにリンクされたロール] を選択し、[サービスの選択] ドロップダウンリストから AnalyticDB for MySQL を選択します。

6. [OK] をクリックします。 [ロール] ページに戻り、サービスにリンクされたロールが作成されているかどうかを確認します。

RAMユーザーに管理権限を付与

RAMユーザーがゼロETLタスクを作成および管理できるようにするには、次の操作を実行する必要があります。

RAMユーザーにAnalyticDB for MySQLを管理する権限を付与する

RAMユーザーがAnalyticDB for MySQLのゼロETLタスクを作成および管理する前に、AnalyticDB for MySQLのAliyunADBFullAccessポリシーをRAMユーザーにアタッチする必要があります。 詳細については、「RAMユーザーへの権限付与」をご参照ください。

RAMユーザーにゼロETL機能を管理する権限を付与する

RAMユーザーがゼロETLタスクを作成および管理する前に、RAMユーザーはデータソースとAnalyticDB for MySQLの間でデータ同期タスクを作成する権限を持っている必要があります。 RAMユーザーがデータソースおよびAnalyticDB for MySQLのすべてのインスタンスまたはクラスターのデータ同期タスクを作成できるようにするカスタムポリシーを設定できます。 RAMユーザーが特定のインスタンスまたはクラスターのデータ同期タスクを作成できるようにするカスタムポリシーを設定することもできます。 次に、カスタムポリシーをRAMユーザーにアタッチできます。 詳細については、「カスタムポリシーの作成」をご参照ください。

次のセクションでは、カスタムポリシーのスクリプトについて説明します。

{
    "Version": "1",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "dts:*",
            "Resource": [
                "acs:adb:*:*:*",
                "acs:polardb:*:*:*"
            ]
        },
        {
            "Effect": "Allow",
            "Action": [
                "dts:DescribeRegions",
                "dts:DescribeConfigRelations",
                "dts:DescribeSrcLinkConfig",
                "dts:DescribeDestLinkConfig",
                "dts:DescribeLinkConfig"
            ],
            "Resource": [
                "acs:dts:*:*:*"
            ]
        }
    ]
}

{
    "Version": "1",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "dts:*",
            "Resource": [
                "acs:adb:*:*:dbcluster/am-2zeod8ax4b9a****",
                "acs:polardb:*:*:dbcluster/pc-bp13jqn4a26b0****"
            ]
        },
        {
            "Effect": "Allow",
            "Action": [
                "dts:DescribeRegions",
                "dts:DescribeConfigRelations",
                "dts:DescribeSrcLinkConfig",
                "dts:DescribeDestLinkConfig",
                "dts:DescribeLinkConfig"
            ],
            "Resource": "acs:dts:*:*:*"
        }
    ]
}

手順

1. AnalyticDB for MySQL コンソールにログインします。 ホームページの左上でリージョンを選択します。 左側のナビゲーションウィンドウで、クラスターリスト をクリックします。 クラスターリスト ページで、エディションタブをクリックします。 管理するクラスターを確認し、クラスター ID をクリックします。

2. クラスターエディションに基づいてzero-ETL設定ページに移動します。

   • の場合、 Data Lakehouse Editionクラスター: 左側のナビゲーションウィンドウで、[データ取り込み] > [データベースデータ同期] を選択します。

   • の場合、 Data Warehouse Editionクラスター: 左側のナビゲーションウィンドウで、[Data Transmission Service] > [Zero-ETL] を選択します。

3. [ゼロETLタスクの作成] をクリックします。 [ゼロETLタスクの作成] ページの [ソースデータベースと宛先データベースの設定] で、ソースデータベースと宛先データベースのパラメーターを設定します。

   • 次の表に、ソースデータベースのパラメーターを示します。

     パラメーター	説明
     タスク名	ゼロETLタスクの名前。
     データベースタイプ	ソースデータベースのデータベースエンジン。 [PolarDB for MySQL] を選択します。
     アクセス方法	ソースデータベースのアクセス方法。 値は自動的にAlibaba Cloudインスタンスに設定されます。
     インスタンスリージョン	PolarDB for MySQLクラスターが存在するリージョン。
     PolarDBクラスターID	PolarDB for MySQLクラスターのID。
     データベースアカウント	PolarDB for MySQLクラスターのデータベースアカウントの名前。
     データベースパスワード	PolarDB for MySQLクラスターのデータベースアカウントのパスワード。
     暗号化	PolarDB for MySQLクラスターへの接続に使用される暗号化方法。 有効な値: 非暗号化およびSSL暗号化。 説明 SSL暗号化を選択した場合、まずPolarDB for MySQLクラスターのSSL暗号化機能を有効にする必要があります。 詳細については、「SSL暗号化の設定」をご参照ください。

   • 次の表に、ターゲットデータベースのパラメーターを示します。

     パラメーター	説明
     データベースエンジン	ターゲットデータベースのデータベースエンジン。 値は自動的にAnalyticDB for MySQL 3.0に設定されます。
     アクセス方法	ターゲットデータベースのアクセス方法。 値は自動的にAlibaba Cloudインスタンスに設定されます。
     インスタンスリージョン	AnalyticDB for MySQLクラスターが存在するリージョン。
     インスタンス ID	AnalyticDB for MySQLクラスターのID。
     データベースアカウント	AnalyticDB for MySQLクラスターのデータベースアカウントの名前。
     データベースパスワード	AnalyticDB for MySQLクラスターのデータベースアカウントのパスワード。

4. 上記のパラメーターを設定した後、[Test Connectivity and Proceed] をクリックします。 [ゼロETLの設定] ステップで、次の表に示すパラメーターを設定します。

   パラメーター	説明
   同期タイプ	ソースデータベースとターゲットデータベース間のデータ同期のタイプ。 有効な値: スキーマ同期、フルデータ同期、および増分データ同期。 説明 同期タスクの場合、増分データ同期は自動的に選択され、クリアできません。 ソースデータベースの増分データは、リアルタイムでターゲットデータベースに同期されます。 増分データを同期しない場合は、データ移行機能を使用します。
   同期するDDLおよびDML操作	同期するDML操作 (INSERT、UPDATE、DELETE) とDDL操作 (CREATE、ALTER、DROP、TRUNCATE) 。 デフォルトでは、すべての操作が選択されています。
   ソースオブジェクトと選択オブジェクト	ソースデータベース内のオブジェクトと同期するオブジェクト。
   詳細設定 (オプション)	ソースデータベースとターゲットデータベース間の接続が失敗した場合のリトライ時間、およびソースデータベースとターゲットデータベースで発生したその他の問題のリトライ時間。

5. 上記のパラメーターを設定した後、[次へ: データベースフィールドとテーブルフィールドの設定] をクリックします。 [データベースおよびテーブルフィールドの設定] ステップで、次の表に示すパラメーターを設定します。

   パラメーター	説明
   データベース名	選択したデータベースの名前。
   テーブル名	選択したテーブルの名前。
   主キー列	選択したテーブルの主キー列。
   配布キー	選択したテーブルの配布キー列。
   タイプ	テーブルの型。パーティション化されたテーブルまたはレプリケートされたテーブルにすることができます。
   定义ステータス	選択したテーブルのステータス。 テーブルフィールドを設定すると、テーブルのステータスが未定義から定義に変わります。

6. 上記のパラメーターを設定したら、[次へ: タスク設定の保存と事前チェック] をクリックします。

7. 事前チェックが成功した場合は、[開始] をクリックしてゼロETLタスクを開始します。

   zero-ETL設定ページで、zero-ETLタスクの [名前] 、[ソース /宛先] 、および [ステータス] パラメーターを表示できます。