AnalyticDB:ゼロ ETL を使用したデータの同期

サービスリンクロールAnalyticDB for MySQL 用の を作成する

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

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

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

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

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:*",  // DTS のすべてのアクション
            "Resource": [
                "acs:adb:*:*:*", // すべての AnalyticDB for MySQL リソース
                "acs:rds:*:*:*", // すべての RDS リソース
            ]
        },
        {
            "Effect": "Allow", // 許可
            "Action": [
                "dts:DescribeRegions", // リージョンの取得
                "dts:DescribeConfigRelations", // 構成関係の取得
                "dts:DescribeSrcLinkConfig", // ソースリンク構成の取得
                "dts:DescribeDestLinkConfig", // 宛先リンク構成の取得
                "dts:DescribeLinkConfig" // リンク構成の取得
            ],
            "Resource": [
                "acs:dts:*:*:*" // すべての DTS リソース
            ]
        }
    ]
}

{
    "Version": "1",
    "Statement": [
        {
            "Effect": "Allow", // 許可
            "Action": "dts:*", // DTS のすべてのアクション
            "Resource": [
                "acs:adb:*:*:dbcluster/am-2zeod8ax4b9a****", // 特定の AnalyticDB for MySQL クラスタ
                "acs:rds:*:*:dbinstance/rm-2ze6fs8ouh43****", // 特定の RDS インスタンス
            ]
        },
        {
            "Effect": "Allow", // 許可
            "Action": [
                "dts:DescribeRegions", // リージョンの取得
                "dts:DescribeConfigRelations", // 構成関係の取得
                "dts:DescribeSrcLinkConfig", // ソースリンク構成の取得
                "dts:DescribeDestLinkConfig", // 宛先リンク構成の取得
                "dts:DescribeLinkConfig" // リンク構成の取得
            ],
            "Resource": "acs:dts:*:*:*" // すべての DTS リソース
        }
    ]
}

手順

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

2. クラスタエディションに基づいて、ゼロ ETL 構成ページに移動します。

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

   • Data Warehouse Edition クラスタの場合: 左側のナビゲーションウィンドウで、<[データ伝送サービス] > [ゼロ ETL] を選択します。

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

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

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

   • 次の表に、宛先クラスタのパラメータを示します。

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

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

   パラメータ	説明
   同期する DDL 操作と DML 操作	同期する DML 操作（[挿入]、[更新]、[削除]）と DDL 操作（[作成]、[変更]、[削除]、[切り捨て]）。 デフォルトでは、すべての操作が選択されています。
   ソースオブジェクトと選択済みオブジェクト	ソースオブジェクトと同期するオブジェクト。
   詳細設定（オプション）	ソースインスタンスと宛先インスタンスおよびクラスタ間の接続失敗の再試行時間、およびソースインスタンスと宛先インスタンスおよびクラスタで発生するその他の問題の再試行時間。

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

   パラメータ	説明
   データベース名	選択したデータベースの名前。
   テーブル名	選択したテーブルの名前。
   プライマリキー列	選択したテーブルのプライマリキー列。
   分散キー	選択したテーブルの分散キー列。
   タイプ	選択したテーブルのタイプ。パーティションテーブルまたはレプリケートされたテーブルです。
   定義ステータス	選択したテーブルのステータス。 テーブルフィールドを設定すると、テーブルのステータスが [未定義] から [定義済み] に変わります。

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

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

   [ゼロ ETL 構成] ページで、ゼロ ETL タスクの [名前]、[ソース/宛先]、[ステータス] パラメータを表示できます。

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

2. 監視情報を表示します。

   1. 左側のナビゲーションウィンドウで、[クラウドサービス監視] > [クラウドサービス監視] を選択します。

   2. [AnalyticDB For MySQL] カードにポインターを移動し、[AnalyticDB For Mysql 3.0 - ZeroETL Latency] をクリックします。

   3. 管理するクラスターを見つけ、クラスター ID をクリックして、ゼロ ETL タスクに関する監視情報を表示します。

3. アラートルールを作成します。

   1. 左側のナビゲーションウィンドウで、[アラート] > [アラートルール] を選択します。

   2. [アラートルールの作成] をクリックします。[アラートルールの作成] パネルで、ゼロ ETL タスクのアラートルールパラメーターを設定します。詳細については、「アラートルールを作成する」をご参照ください。

      説明

      [製品] パラメーターには [AnalyticDB For Mysql 3.0 - ZeroETL Latency] を選択する必要があります。

4. サブスクリプションポリシーを作成します。

   1. 左側のナビゲーションウィンドウで、[イベントセンター] > [イベントサブスクリプション] を選択します。

   2. [サブスクリプションポリシーの作成] をクリックします。[サブスクリプションポリシーの作成] ページで、ゼロ ETL タスクのサブスクリプションポリシーパラメーターを設定します。詳細については、「イベントサブスクリプションポリシーを管理する（推奨）」トピックの「サブスクリプションポリシーを作成する」セクションをご参照ください。

      説明

      • [製品]: [AnalyticDB For MySQL V3.0] を選択します。

      • [イベントタイプ]: [異常] または [復旧] を選択します。

      • [イベント名]: [zero_etl_job_abnormal] または [zero_etl_job_restore] を選択します。