Batch create MaxCompute foreign tables - AnalyticDB - Alibaba Cloud Documentation Center

AnalyticDB for MySQL mendukung pembuatan batch MaxCompute foreign tables menggunakan pernyataan IMPORT FOREIGN SCHEMA.

Prasyarat

Kluster AnalyticDB for MySQL harus menggunakan versi 3.2.2.0 atau lebih baru.

Catatan
Untuk melihat dan memperbarui versi minor, buka bagian Configuration Information pada halaman Cluster Information di Konsol AnalyticDB for MySQL.
Elastic Network Interface (ENI) harus diaktifkan untuk kluster AnalyticDB for MySQL.
Penting
- Masuk ke Konsol AnalyticDB for MySQL. Pada halaman Cluster Information, aktifkan sakelar jaringan ENI di bagian Network Information.
- Mengaktifkan atau menonaktifkan jaringan ENI akan mengganggu koneksi database selama sekitar dua menit. Selama periode ini, operasi baca dan tulis tidak tersedia. Evaluasi dampak potensial sebelum melanjutkan.
Proyek MaxCompute dan kluster AnalyticDB for MySQL harus berada di wilayah yang sama.
Blok CIDR VPC untuk kluster AnalyticDB for MySQL harus termasuk dalam daftar putih alamat IP proyek MaxCompute.

Catatan
Masuk ke Konsol AnalyticDB for MySQL dan temukan ID VPC pada halaman Cluster Information. Kemudian, masuk ke Konsol VPC dan temukan blok CIDR pada halaman VPC berdasarkan ID VPC tersebut. Untuk informasi lebih lanjut tentang cara mengonfigurasi daftar putih alamat IP untuk MaxCompute, lihat Manage IP address whitelists.
Server eksternal harus dibuat di AnalyticDB for MySQL. Untuk informasi lebih lanjut tentang sintaks, lihat Manage foreign servers.

Sintaks

IMPORT FOREIGN SCHEMA odps_project
[LIMIT TO (table_name[, …])]
FROM server_name
INTO adb_schema
[OPTIONS (
 if_table_exist 'error|ignore|update', 
 if_type_unsupport 'error|ignore',
 table_prefix 'table_prefix',
 table_suffix 'table_suffix')]

Parameter

Parameter	Wajib	Deskripsi
`odps_project`	Ya	Nama proyek MaxCompute.
`table_name[,…]`	Tidak	Nama tabel MaxCompute yang akan diimpor. Jika Anda tidak menentukan nama tabel, sistem akan mengimpor semua tabel dari proyek MaxCompute yang ditentukan sebagai foreign tables ke dalam AnalyticDB for MySQL.
`server_name`	Ya	Nama server eksternal. Untuk detail sintaks, lihat Manage foreign servers.
`adb_schema`	Ya	Nama database tujuan AnalyticDB for MySQL.
`if_table_exist`	Tidak	Kebijakan untuk menangani konflik penamaan jika tabel dengan nama yang sama sudah ada di database tujuan AnalyticDB for MySQL. Nilai yang valid: error (Default): Melaporkan error dan mencantumkan tabel yang bentrok. Operasi gagal dan tidak ada tabel yang diimpor. ignore: Melewatkan pembuatan tabel yang memiliki konflik penamaan dan membuat tabel lainnya. update: Menimpa tabel yang sudah ada dan membuat tabel lainnya.
`if_type_unsupport`	Tidak	Kebijakan untuk menangani tipe data yang tidak didukung oleh AnalyticDB for MySQL. Nilai yang valid: error (Default): Melaporkan error, mencantumkan tabel yang berisi tipe data yang tidak didukung beserta jenis tipe datanya. ignore: Melewatkan pembuatan tabel yang berisi tipe data yang tidak didukung.
`table_prefix`	Tidak	Awalan yang ditambahkan ke nama setiap foreign table yang diimpor. Secara default, foreign tables di AnalyticDB for MySQL memiliki nama yang sama dengan tabel sumber di MaxCompute.
`table_suffix`	Tidak	Akhiran yang ditambahkan ke nama setiap foreign table yang diimpor. Secara default, foreign tables di AnalyticDB for MySQL memiliki nama yang sama dengan tabel sumber di MaxCompute.

Contoh

Di AnalyticDB for MySQL, buat foreign tables MaxCompute pre_customer_suf dan pre_order_suf.

IMPORT FOREIGN SCHEMA my_project
LIMIT TO (customer, order)
FROM maxcompute_server
INTO my_adb_schema
OPTIONS (
    if_table_exist 'update',
    if_type_unsupport 'ignore',
    table_prefix 'pre_',
    table_suffix '_suf'
);

Manage foreign servers

Create foreign server

Sintaks

CREATE SERVER <server_name>
TYPE = 'ODPS'
SERVER_PROPERTIES = '{
	"endpoint":"<endpoint>",
	"accessid":"<accesskey_id>",
	"accesskey":"<accesskey_secret>"
}'

Parameter

Parameter	Wajib	Deskripsi
`server_name`	Ya	Nama server eksternal. Nama harus dimulai dengan huruf atau garis bawah (_), hanya boleh berisi huruf, angka, dan garis bawah, serta panjangnya tidak lebih dari 64 karakter.
`TYPE='ODPS'`	Ya	Jenis server eksternal. Tetapkan nilainya ke ODPS.
`endpoint`	Ya	Titik akhir MaxCompute. Catatan Anda hanya dapat mengakses MaxCompute melalui endpoint VPC. Untuk informasi lebih lanjut tentang endpoint MaxCompute, lihat Endpoints.
`accessid`	Ya	ID AccessKey dari Akun Alibaba Cloud atau MaxCompute yang memiliki izin untuk mengakses MaxCompute. Untuk mendapatkan ID AccessKey dan Rahasia AccessKey, lihat Accounts and permissions.
`accesskey`	Ya	Rahasia AccessKey dari Akun Alibaba Cloud atau MaxCompute yang memiliki izin untuk mengakses MaxCompute. Untuk mendapatkan ID AccessKey dan Rahasia AccessKey, lihat Accounts and permissions.

Contoh

CREATE SERVER maxcompute_server
TYPE = 'ODPS'
SERVER_PROPERTIES = '{
    "endpoint":"http://service.cn-hangzhou-vpc.maxcompute.aliyun-inc.com/api",
    "accessid":"STS.****************",
    "accesskey":"yourAccessKeySecret"
}';

Query foreign servers

Query all foreign servers

SHOW SERVER

Query a specific foreign server

Sintaks

SHOW SERVER WHERE SERVER_NAME='<server_name>'

Parameter

Parameter	Wajib	Deskripsi
`server_name`	Ya	Nama server eksternal.

Contoh

SHOW SERVER WHERE SERVER_NAME='maxcompute_server';

Query foreign servers by type

Sintaks

SHOW SERVER WHERE SERVER_TYPE='<server_type>'

Parameter

Parameter	Wajib	Deskripsi
`server_type`	Ya	Jenis server eksternal. Jenis server untuk MaxCompute adalah ODPS.

Contoh

SHOW SERVER WHERE SERVER_TYPE='ODPS';

Rename foreign server

Sintaks

ALTER SERVER <server_name> RENAME <new_server_name>

Parameter

Parameter	Wajib	Deskripsi
`server_name`	Ya	Nama asli server eksternal.
`new_server_name`	Ya	Nama baru server eksternal.

Contoh

ALTER SERVER maxcompute_server RENAME mc_server;

Delete foreign server

Catatan

Menghapus server eksternal akan menghentikan koneksi antara AnalyticDB for MySQL dan MaxCompute.

Sintaks

DROP SERVER <server_name>

Parameter

Parameter	Wajib	Deskripsi
`server_name`	Ya	Nama server eksternal.

Contoh

DROP SERVER maxcompute_server;