ApsaraDB RDS:AnalyticDB for MySQL へのクラウドディスクバックアップデータのインポート

前提条件

• RDS for MySQL インスタンスは クラウドディスク インスタンスであり、高度なダウンロード機能をサポートしている必要があります。 サポートされているインスタンスの詳細については、「前提条件」をご参照ください。

• 移行先となる、クラウドネイティブデータウェアハウスである AnalyticDB for MySQL クラスターが作成済みであること。 詳細については、「Data Warehouse Edition クラスターの作成」または「Data Lakehouse Edition クラスターの作成」をご参照ください。

• AnalyticDB for MySQL クラスタがエラスティック モードの場合、クラスター情報 ページの ネットワーク情報 セクションで Eniネットワーク を有効にする必要があります。

  重要

  ENI を有効または無効にすると、データベース接続が約 2 分間中断される場合があります。この間、読み取りまたは書き込み操作を実行することはできません。ENI を有効または無効にする場合は注意してください。

注意事項

AnalyticDB for MySQL は、CSV または Parquet 形式のデータファイルのインポートのみをサポートしています。 RDS for MySQL の高度なダウンロード機能を使用する場合は、ダウンロード形式として CSV または Parquet を選択する必要があります。

事前準備

次の手順に従って、バックアップダウンロード機能を使用して AnalyticDB for MySQL データをオブジェクトストレージサービス (OSS) のフォルダーに移動します。

1. OSS を有効化します。 詳細については、「OSS の有効化」をご参照ください。

2. OSS コンソールで OSS バケットを作成します。 詳細については、「コンソールでのバケットの作成」をご参照ください。

   説明

   OSS バケットと AnalyticDB for MySQL クラスターは、同じリージョンにある必要があります。

3. OSS コンソールでフォルダーを作成します。 詳細については、「フォルダーの作成」をご参照ください。

4. 高度なダウンロード機能を使用して、クラウドディスクインスタンスから OSS にバックアップデータをダウンロードします。

   説明

   別のダウンロード先を選択した場合は、バックアップデータを手動で OSS にアップロードする必要があります。 詳細については、「データのアップロード」をご参照ください。

   この例では、ソースの RDS for MySQL データベース名は mydb で、mytable という名前のテーブルが含まれています。 テーブル内のサンプルデータは次のとおりです。

   INSERT INTO mytable (id, name)
   VALUES
       ("12", "hello_world_1"),
       ("27", "hello_world_2"),
       ("28", "hello_world_3"),
       ("33", "hello_world_4"),
       ("37", "hello_world_5"),
       ("40", "hello_world_6");

   高度なダウンロード機能を使用して、mytable テーブルのデータを OSS パス oss://bucket/_export/mydb/mytable/data/0-1csv に保存します。

OSS データの AnalyticDB for MySQL へのインポート

この例では、oss://bucket/_export/mydb/mytable/data/0-1csv のデータを、AnalyticDB for MySQL の adb_demo データベースにインポートします。

1. AnalyticDB for MySQL クラスタに接続します。詳細については、「AnalyticDB for MySQL クラスタに接続する」をご参照ください。

2. データベースを作成します。詳細については、「データベースを作成する」をご参照ください。

   この例では、adb_demo という名前のデータベースが AnalyticDB for MySQL クラスタに作成されます。

3. 外部マッピングテーブルを作成します。

   説明

   外部マッピングテーブルを作成する際には、ソーステーブルと同じ名前を使用することも、別の名前を指定することもできます。

   AnalyticDB for MySQL はテーブルレベルの分析のみをサポートしており、データベース全体の分析はサポートしていません。 したがって、分析を実行する前に、AnalyticDB for MySQL データベースにマッピングテーブルを作成する必要があります。 CREATE TABLE ステートメントを使用して、移行先の adb_demo データベースに CSV または Parquet 形式の OSS 外部マッピングテーブルを作成します。 この例では、パーティションのないデータファイルに対して、CSV 形式で OSS 外部マッピングテーブルを作成する方法を示します。 構文の詳細については、「パーティションのないデータファイルからの OSS 外部テーブルの作成」をご参照ください。

   CREATE TABLE IF NOT EXISTS mytable
   (
       id string,
       name string
   )
   ENGINE='OSS'
   TABLE_PROPERTIES='{
       "endpoint":"oss-cn-hangzhou-internal.aliyuncs.com",
       "url":"oss://bucket/_export/mydb/mytable/data/0-1csv",
       "accessid":"LTAI****************",
       "accesskey":"yourAccessKeySecret",
       "delimiter":",",
       "format":"csv"
   }';

   パラメーター	説明
   ENGINE='OSS'	テーブルエンジン。値を OSS に設定します。
   TABLE_PROPERTIES	AnalyticDB for MySQL が OSS 内のデータにアクセスする方法を指定します。
   endpoint	OSS バケットの [エンドポイント]。AnalyticDB for MySQL は、VPC (Virtual Private Cloud) を使用してのみ OSS にアクセスできます。 説明 OSS コンソール にログインし、バケットを見つけ、[概要] ページで [エンドポイント] を取得します。
   url	OSS 内のソースデータファイルまたはフォルダーへの絶対パス。 フォルダーパスはスラッシュ (/) で終わらせることを推奨します。 例： ファイル：oss://<bucket-name>/adb/oss_import_test_data.csv。 フォルダー：oss://<bucket-name>/adb_data/。 注 フォルダーパスを指定した場合、作成後の外部テーブルにはそのフォルダー配下のすべてのデータが含まれます。
   accessid	OSS に対する権限を持つ Alibaba Cloud アカウントまたは RAM (Resource Access Management) ユーザーの AccessKey ID。 AccessKey ID と AccessKey secret を取得する方法については、「アカウントと権限」をご参照ください。
   accesskey	OSS のファイルまたはフォルダーにアクセスするための AccessKey secret です。
   delimiter	CSV オブジェクトの列区切り文字。
   format	データファイルの形式です。 Parquet ファイル用の外部テーブルを作成するには、このパラメーターを parquet に設定します。 ORC ファイル用の外部テーブルを作成するには、このパラメーターを orc に設定します。 説明 形式を指定しない場合、デフォルトは CSV です。

   説明

   ダウンロードしたテーブルが 0-1csv や 0-2csv のように複数の CSV ファイルに分割されている場合は、url パラメーターをデータファイルの親ディレクトリに設定します："url":"oss://bucket/_export/mydb/mytable/data/"。 AnalyticDB for MySQL は、このパス内のすべてのファイルを mytable テーブルにマージします。

   この時点で、mytable テーブルが AnalyticDB for MySQL データベースに作成されます。 テーブルの内容は、ソースの mytable テーブルの内容と同じです。 これで、テーブルをクエリできます。

4. 次のステートメントを実行して、インポートされたデータをクエリします。

   -- mytable はデータベース内のテーブル名です
   SELECT * FROM mytable;

   クエリは、ソースの mytable テーブルと同じ内容のテーブルを返します。

   テーブルには id と name の 2 つの列があり、6 つのレコードが含まれています。 name の値の範囲は、hello_world_1 から hello_world_6 です。