ApsaraDB RDS:Impor data dari instans ApsaraDB RDS for MySQL yang menggunakan disk cloud ke AnalyticDB for MySQL kluster

Prasyarat

• Instans RDS menggunakan disk cloud dan mendukung fitur unduhan lanjutan. Untuk informasi lebih lanjut, lihat Unduh File Cadangan.

• Kluster AnalyticDB for MySQL telah dibuat. Untuk informasi lebih lanjut, lihat Buat Kluster Data Warehouse Edition atau Buat Kluster Data Lakehouse Edition.

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

  Penting

  Saat mengaktifkan atau menonaktifkan ENI, koneksi database mungkin terputus selama sekitar 2 menit. Selama periode ini, operasi baca atau tulis tidak dapat dilakukan. Lanjutkan dengan hati-hati.

Catatan penggunaan

AnalyticDB for MySQL mendukung impor file CSV dan Parquet. Saat mengunduh file cadangan dari instans RDS, atur format unduhan ke CSV atau Parquet.

Persiapan

Buat direktori di bucket OSS untuk menyimpan data kluster AnalyticDB for MySQL. Gunakan fitur unduhan cadangan untuk mengunduh data yang diperlukan ke bucket OSS. Untuk informasi lebih lanjut, lihat Apa itu OSS?

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

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

   Catatan

   Pastikan bahwa bucket OSS dan kluster AnalyticDB for MySQL berada di wilayah yang sama.

3. Buat direktori di konsol OSS. Untuk informasi lebih lanjut, lihat Kelola Direktori.

4. Gunakan fitur unduhan cadangan untuk mengunduh file cadangan dari instans RDS dan atur parameter Tujuan Unduhan ke OSS. Untuk informasi lebih lanjut, lihat Unduh File Cadangan.

   Catatan

   Jika memilih nilai lain untuk parameter ini, unggah file cadangan ke bucket OSS. Untuk informasi lebih lanjut, lihat Unggah Objek.

   Dalam contoh ini, nama basis data sumber pada instans RDS adalah mydb, dan tabel mytable dibuat di basis data tersebut. Contoh data dalam tabel:

   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 unduhan cadangan untuk mengunduh data dari tabel mytable ke direktori /bucket/_export/mydb/mytable/data/0-1csv di bucket OSS.

Impor data dari bucket OSS ke kluster AnalyticDB for MySQL

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

1. Hubungkan ke kluster AnalyticDB for MySQL. Untuk informasi lebih lanjut, lihat Hubungkan ke Kluster AnalyticDB for MySQL.

2. Buat basis data. Untuk informasi lebih lanjut, lihat Buat Basis Data.

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

3. Buat tabel pemetaan eksternal.

   Catatan

   Saat membuat tabel pemetaan eksternal, gunakan nama tabel yang sama dengan tabel asli atau pilih nama tabel yang berbeda.

   AnalyticDB for MySQL hanya mendukung analisis tabel. Pastikan tabel pemetaan dibuat di kluster AnalyticDB for MySQL sebelum analisis data. Jalankan pernyataan CREATE TABLE untuk membuat tabel pemetaan eksternal OSS dalam format CSV atau Parquet di basis data adb_demo. Dalam contoh ini, tabel pemetaan eksternal OSS tanpa partisi dan dalam format CSV dibuat. Untuk informasi lebih lanjut tentang sintaks, lihat Gunakan Tabel Eksternal untuk Mengimpor Data ke Data Warehouse Edition.

   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. Atur nilainya menjadi OSS.
   TABLE_PROPERTIES	Informasi koneksi yang digunakan oleh AnalyticDB for MySQL untuk mengakses OSS.
   endpoint	endpoint dari bucket OSS. AnalyticDB for MySQL hanya dapat mengakses OSS melalui virtual private cloud (VPC). Catatan Anda dapat masuk ke konsol OSS, temukan bucket, dan kemudian peroleh endpoint di halaman Overview.
   url	Path absolut dari objek atau direktori sumber di OSS. Kami merekomendasikan menggunakan garis miring (/) di akhir path absolut direktori. Contoh: Objek: oss://<bucket-name>/adb/oss_import_test_data.csv. Direktori: oss://<bucket-name>/adb_data/.
   accessid	ID AccessKey yang digunakan untuk mengakses objek atau direktori di OSS. Untuk informasi lebih lanjut tentang cara memperoleh ID AccessKey dan Rahasia AccessKey, lihat Akun dan izin.
   accesskey	Rahasia AccessKey yang digunakan untuk mengakses objek atau direktori di OSS.
   delimiter	Pemisah kolom dari objek CSV.
   format	Saat Anda membuat tabel eksternal dalam format Parquet, Anda harus menyetel parameter ini ke parquet. Saat Anda membuat tabel eksternal dalam format ORC, Anda harus menyetel parameter ini ke orc. Catatan Jika parameter format tidak ditentukan, format CSV digunakan.

   Catatan

   Jika tabel dalam file yang diunduh disimpan dalam beberapa file CSV, seperti 0-1csv dan 0-2csv, ubah URL menjadi "url":"oss://bucket/_export/mydb/mytable/data/". Kemudian, AnalyticDB for MySQL menggabungkan file dalam direktori ini ke dalam tabel analisis mytable.

   Dengan cara ini, tabel mytable akan tersedia di kluster AnalyticDB for MySQL. Konten tabel ini persis sama dengan tabel mytable asli. Anda dapat menanyakan data di tabel mytable.

4. Jalankan pernyataan berikut untuk menanyakan data yang diimpor:

   -- mytable adalah nama tabel di basis data di kluster AnalyticDB for MySQL.
   SELECT * FROM mytable;

   Data dalam tabel yang ditanyakan dikembalikan. Data yang dikembalikan persis sama dengan tabel mytable asli.