Realtime Compute for Apache Flink:Kelola katalog MySQL

UI (direkomendasikan)

1. Pergi ke halaman Katalog.

   1. Masuk ke Konsol Realtime Compute for Apache Flink. Temukan ruang kerja yang ingin Anda kelola dan klik Console di kolom Actions.

   2. Di panel navigasi di sebelah kiri, klik Manajemen Data.

2. Di halaman Daftar Katalog, klik Create Catalog. Di tab Katalog Bawaan dari kotak dialog Buat Katalog, klik MySQL dan klik Next.

3. Di langkah Konfigurasi Katalog, konfigurasikan parameter.

   Penting

   Setelah katalog dibuat, konfigurasi parameter berikut tidak dapat dimodifikasi. Untuk memodifikasi katalog, Anda harus menghapusnya dan membuat yang baru.

   

   Parameter	Deskripsi	Diperlukan
   catalogname	Nama katalog MySQL kustom.	Ya
   hostname	Alamat IP atau nama host yang digunakan untuk mengakses database MySQL. Catatan Jika instance MySQL tidak berada di VPC yang sama dengan Realtime Compute for Apache Flink atau Anda ingin mengakses instance MySQL dan Realtime Compute for Apache Flink melalui Internet, Anda harus membuat koneksi jaringan. Untuk informasi lebih lanjut, lihat FAQ tentang konektivitas jaringan.	Ya
   port	Nomor port database MySQL. Nilai default: 3306.	Tidak
   default-database	Nama database MySQL default.	Ya
   username	Nama pengguna yang digunakan untuk mengakses database MySQL.	Ya
   password	Kata sandi yang digunakan untuk mengakses database MySQL. Untuk mencegah risiko yang disebabkan oleh pasangan AccessKey dalam teks biasa, kami sarankan Anda menggunakan variabel untuk menentukan parameter ini. Pada gambar sampel, variabel bernama mysqlpw digunakan. Untuk informasi lebih lanjut, lihat Buat variabel.	Ya

4. Klik Confirm.

   Di panel Catalogs di sebelah kiri halaman Daftar Katalog, lihat katalog yang telah Anda buat.

SQL

1. Pergi ke halaman Skrip.

   1. Masuk ke Konsol Realtime Compute for Apache Flink. Temukan ruang kerja yang ingin Anda kelola dan klik Console di kolom Actions.

   2. Di panel navigasi di sebelah kiri, pilih Development > Scripts.

2. Klik dan pilih New Script. Di kotak dialog, masukkan nama skrip, pilih lokasi, lalu klik Save.

3. Salin dan tempel kode berikut:

   CREATE CATALOG YourCatalogName WITH(
     'type' = 'mysql',
     'hostname' = 'rm-bp1gcn0q0j0******.mysql.rds.aliyuncs.com',
     'port' = '3306',
     'username' = 'usertest',
     'password' = '${secret_values.mysqlpw}',
     'default-database' = 'flinktest',
     'catalog.table.metadata-columns'='table_name'
   );

   Opsi	Deskripsi	Diperlukan
   YourCatalogName	Nama katalog MySQL kustom.	Ya
   type	Tipe katalog. Atur nilainya menjadi mysql.	Ya
   hostname	Alamat IP atau nama host yang digunakan untuk mengakses database MySQL. Catatan Untuk mengakses MySQL lintas VPC atau melalui Internet, Anda harus membuat koneksi jaringan. Untuk informasi lebih lanjut, lihat FAQ tentang konektivitas jaringan.	Ya
   port	Nomor port database MySQL. Nilai default: 3306.	Tidak
   default-database	Nama database MySQL default.	Ya
   username	Nama pengguna yang digunakan untuk mengakses database MySQL.	Ya
   password	Kata sandi yang digunakan untuk mengakses database MySQL. Untuk mencegah risiko yang disebabkan oleh pasangan AccessKey dalam teks biasa, kami sarankan Anda menggunakan variabel untuk menentukan opsi ini. Kode sampel menggunakan variabel bernama mysqlpw. Untuk informasi lebih lanjut, lihat Buat variabel.	Ya
   property-version	Versi opsi katalog. Nilai valid: 0 dan 1. Sementara 0 adalah nilai default, 1 direkomendasikan. Opsi yang tersedia dan nilai default dari opsi tersebut dapat bervariasi berdasarkan versi opsi katalog. Untuk informasi lebih lanjut, lihat deskripsi opsi. Catatan Hanya VVR 8.0.6 atau lebih baru yang mendukung opsi ini. Di VVR 11.1 atau lebih baru, nilai default adalah 1.	Tidak
   catalog.table.metadata-columns	Kolom metadata dalam tabel sumber CDC MySQL yang ingin Anda tambahkan ke skema tabel saat Anda menanyakan tabel. Secara default, tidak ada kolom metadata yang ditambahkan. Pisahkan beberapa kolom metadata dengan titik koma (;). Contoh: op_ts;table_name;database_name. Catatan Hanya VVR 6.0.5 atau lebih baru yang mendukung opsi ini. Jika Anda menentukan opsi ini, kolom metadata yang ditentukan akan ditambahkan ke skema tabel yang dikembalikan. Kolom metadata hanya tersedia di tabel sumber CDC MySQL. Oleh karena itu, tabel yang dibuat di katalog MySQL dapat digunakan hanya sebagai tabel sumber dan tidak dapat digunakan sebagai tabel sink atau tabel dimensi.	Tidak
   catalog.table.treat-tinyint1-as-boolean	Menentukan apakah akan memetakan tipe data TINYINT(1) dan BOOLEAN dari MySQL ke tipe data BOOLEAN dari Flink saat Realtime Compute for Apache Flink mendapatkan skema tabel. Nilai valid: true: Tipe data TINYINT(1) dan BOOLEAN dari MySQL dipetakan ke tipe data BOOLEAN dari Flink. false: Tipe data TINYINT(1) dan BOOLEAN dari MySQL dipetakan ke tipe data TINYINT dari Flink. Nilai default: Jika Anda mengatur opsi property-version ke 0, nilai default opsi ini adalah true. Jika Anda mengatur opsi property-version ke 1, nilai default opsi ini adalah false. Catatan Hanya VVR 8.0.4 atau lebih baru yang mendukung opsi ini. Kami sarankan Anda menggunakan bidang tipe data TINYINT(1) dari MySQL untuk menyimpan hanya nilai 0 dan 1. Anda harus memilih tipe data yang sesuai dengan kebutuhan bisnis Anda untuk pemetaan. Untuk informasi lebih lanjut, lihat Pemetaan tipe data.	Tidak

4. Pilih kode untuk pembuatan katalog dan klik Run di sebelah kiri kode.

   Pesan Pernyataan berikut telah berhasil dieksekusi! menunjukkan bahwa katalog telah dibuat.

   

UI (direkomendasikan)

Di halaman Catalogs, klik katalog yang telah dibuat untuk melihat parameter Name dan Type katalog di bagian Catalog List.

• Lihat katalog: Klik View di kolom Actions katalog yang ingin Anda kelola dan lihat database dan tabel di katalog.

  Bidang komentar tidak ditampilkan dalam detail skema tabel.

• Hapus katalog: Klik Delete di kolom Actions katalog yang ingin Anda hapus.

  Operasi penghapusan hanya menghapus katalog yang Anda buat dan tidak menghapus tabel di layanan terkait. Setelah katalog dihapus, penyebaran yang sedang berjalan yang menggunakan tabel di katalog tidak terpengaruh secara negatif. Jika penyebaran diredploy atau dimulai ulang, kesalahan akan terjadi, menunjukkan bahwa tabel tidak dapat ditemukan. Berhati-hatilah saat melakukan operasi penghapusan.

SQL

1. Di editor kode tab Skrip di halaman Skrip, masukkan kode berikut:

   -- Lihat informasi skema tabel di katalog. Bidang komentar tidak ditampilkan.
   DESCRIBE `<catalogname>`.`<dbname>`.`<tablename>`;
   
   -- Hapus katalog.
   DROP CATALOG `<catalogname>`;

   Catatan

   Operasi penghapusan hanya menghapus katalog yang Anda buat dan tidak menghapus tabel di layanan terkait. Setelah katalog dihapus, penyebaran yang sedang berjalan yang menggunakan tabel di katalog tidak terpengaruh. Jika penyebaran diredploy atau dimulai ulang, kesalahan akan terjadi menunjukkan bahwa tabel tidak dapat ditemukan. Berhati-hatilah saat melakukan operasi penghapusan.

2. Klik kanan pernyataan dan pilih Run dari menu pintasan.