ApsaraDB RDS:Impor data backup cloud disk ke AnalyticDB for MySQL

Prasyarat

• Instans RDS for MySQL harus merupakan instans cloud disk dan mendukung fitur Advanced Download. Untuk informasi lebih lanjut mengenai instans yang didukung, lihat Prasyarat.

• Anda telah membuat kluster gudang data cloud-native AnalyticDB for MySQL. Untuk informasi lebih lanjut, lihat Buat kluster Edisi Data Warehouse atau Buat kluster Edisi Data Lakehouse.

• Jika kluster AnalyticDB for MySQL berada dalam mode elastis, Anda harus mengaktifkan ENI pada bagian Network Information di halaman Cluster Information.

  Penting

  Saat Anda mengaktifkan atau menonaktifkan ENI, koneksi database mungkin terputus selama kurang lebih 2 menit. Selama periode ini, Anda tidak dapat melakukan operasi baca atau tulis. Lakukan tindakan ini dengan hati-hati.

Catatan

AnalyticDB for MySQL hanya mendukung pengimporan file data dalam format CSV atau Parquet. Saat menggunakan fitur unduh backup RDS for MySQL, Anda harus memilih CSV atau Parquet sebagai format unduhan.

Persiapan

Ikuti langkah-langkah berikut untuk menggunakan fitur unduh backup guna memindahkan data AnalyticDB for MySQL ke folder di Object Storage Service (OSS).

1. Aktifkan OSS. Untuk informasi lebih lanjut, lihat Aktifkan OSS.

2. Buat bucket OSS di Konsol OSS. Untuk informasi lebih lanjut, lihat Buat bucket di konsol.

   Catatan

   Bucket OSS dan kluster AnalyticDB for MySQL harus berada di wilayah yang sama.

3. Buat folder di Konsol OSS. Untuk informasi lebih lanjut, lihat Buat folder.

4. Anda dapat menggunakan fitur Download Backup untuk mengunduh data backup dari instans cloud disk ke OSS.

   Catatan

   Jika Anda memilih tujuan unduh yang berbeda, Anda harus mengunggah data backup secara manual ke OSS. Untuk informasi lebih lanjut, lihat Unggah data.

   Dalam contoh ini, database RDS for MySQL sumber bernama mydb dan berisi tabel bernama mytable. Data sampel dalam tabel tersebut adalah sebagai berikut:

   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");

   Gunakan fitur unduh backup untuk menyimpan data dari tabel mytable ke jalur OSS /bucket/_export/mydb/mytable/data/0-1csv.

Impor data OSS ke AnalyticDB for MySQL

Dalam contoh ini, data dari /bucket/_export/mydb/mytable/data/0-1csv diimpor ke database adb_demo di AnalyticDB for MySQL.

1. Hubungkan ke kluster AnalyticDB for MySQL. Untuk informasi lebih lanjut, lihat 连接集群.

2. Buat database. Untuk informasi lebih lanjut, lihat Create a database.

   Dalam contoh ini, database bernama adb_demo dibuat di kluster AnalyticDB for MySQL.

3. Buat tabel pemetaan eksternal.

   Catatan

   Saat membuat tabel pemetaan eksternal, Anda dapat menggunakan nama yang sama dengan tabel sumber atau menentukan nama yang berbeda.

   AnalyticDB for MySQL hanya mendukung analisis tingkat tabel dan tidak mendukung analisis basis data penuh. Oleh karena itu, Anda harus membuat tabel pemetaan di database AnalyticDB for MySQL sebelum dapat melakukan analisis. Gunakan pernyataan CREATE TABLE untuk membuat tabel pemetaan eksternal OSS dalam format CSV atau Parquet di database tujuan adb_demo. Contoh ini menunjukkan cara membuat tabel pemetaan eksternal OSS dalam format CSV untuk file data yang tidak memiliki partisi. Untuk informasi lebih lanjut mengenai sintaksisnya, lihat Creating an OSS external table from data files without partitions.

   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"
   }';

   Parameter	Deskripsi
   ENGINE='OSS'	Mesin tabel. Tetapkan parameter ini ke OSS.
   TABLE_PROPERTIES	Menentukan cara AnalyticDB for MySQL mengakses data di OSS.
   endpoint	Endpoint bucket OSS. AnalyticDB for MySQL hanya dapat mengakses OSS melalui VPC. Catatan Masuk ke Konsol OSS. Klik nama bucket tujuan. Di halaman Overview bucket tersebut, lihat Endpoint.
   url	Jalur mutlak ke file data sumber atau folder di OSS. Disarankan untuk mengakhiri jalur folder dengan garis miring (/). Contoh: File: oss://<bucket-name>/adb/oss_import_test_data.csv. Folder: oss://<bucket-name>/adb_data/. Note Jika Anda menentukan jalur folder, tabel eksternal akan mencakup semua data di bawah folder tersebut setelah dibuat.
   accessid	ID AccessKey dari Akun Alibaba Cloud atau Pengguna RAM yang memiliki izin management pada OSS. Untuk mendapatkan ID AccessKey dan Rahasia AccessKey Anda, lihat Accounts and Permissions.
   accesskey	Rahasia AccessKey Anda untuk mengakses file atau folder di OSS.
   delimiter	Menentukan Pemisah kolom untuk file data CSV.
   format	Format file data. Untuk membuat tabel eksternal untuk file Parquet, tetapkan parameter ini ke parquet. Untuk membuat tabel eksternal untuk file ORC, tetapkan parameter ini ke orc. Catatan Jika Anda tidak menentukan format, nilai default-nya adalah CSV.

   Catatan

   Jika tabel yang diunduh terbagi menjadi beberapa file CSV, seperti 0-1csv dan 0-2csv, tetapkan parameter url ke direktori induk file data tersebut: "url":"oss://bucket/_export/mydb/mytable/data/". AnalyticDB for MySQL akan menggabungkan semua file di jalur ini ke dalam tabel mytable.

   Pada tahap ini, tabel mytable telah dibuat di database AnalyticDB for MySQL. Isi tabel identik dengan isi tabel sumber mytable. Anda kini dapat melakukan kueri terhadap tabel tersebut.

4. Jalankan pernyataan berikut untuk melakukan kueri terhadap data yang diimpor.

   -- mytable adalah nama tabel di database
   SELECT * FROM mytable;

   Kueri mengembalikan tabel yang isinya identik dengan isi tabel sumber mytable.

   Tabel tersebut memiliki dua kolom, id dan name, dengan enam catatan. Nilai name berkisar dari hello_world_1 hingga hello_world_6.