Realtime Compute for Apache Flink：Kelola variabel

Referensikan variabel dalam draf SQL

Anda dapat menggunakan variabel saat mengembangkan draf SQL. Misalnya, Anda dapat menggunakan variabel sebagai parameter input dari fungsi kustom. Anda juga dapat mengubah nilai variabel setelah penyebaran dimulai.

1. Di panel navigasi kiri konsol Realtime Compute for Apache Flink, pilih Development > ETL.

2. Di editor SQL dari draf yang ingin dikembangkan, buat variabel dalam format ${Nama variabel}. Contoh kode berikut memberikan ilustrasi.

   • Jika Anda mereferensikan variabel dalam klausa WITH, apit variabel dengan sepasang tanda kutip tunggal ('), dalam format '${Nama variabel}'.

   • Jika Anda mereferensikan variabel sebagai nama tabel atau nama bidang dalam pernyataan SQL, apit variabel dengan sepasang tanda aksen grave (`), dalam format `${Nama variabel}`.

   create temporary table `${source_name}`(
       id varchar,
       name varchar
   ) with (
       'connector' = 'datagen'
   );
   
   
   create temporary table blackhole(
       id varchar,
       `${test_name}` varchar
   ) with (
       'connector' = '${blackhole}'
   );
   
   insert into blackhole select * from `${source_name}`;

3. Realtime Compute for Apache Flink secara otomatis mengidentifikasi variabel dalam format yang diperlukan dalam draf. Gunakan salah satu metode berikut untuk mengonfigurasi nilai variabel:

   • Metode 1: Masukkan nilai variabel di panel Variables editor SQL.

     

   • Metode 2: Klik tab Configurations di sebelah kanan editor SQL. Di panel Konfigurasi, masukkan nilai variabel di bagian Variables.

     

4. Setelah draf disebarluaskan, lihat variabel yang direferensikan dalam penyebaran pada tab Configuration halaman Deployments.

   

5. Di halaman Deployments, cari deployment yang ingin Anda mulai, lalu klik Start pada kolom Actions. Anda dapat mengubah nilai variabel di panel Start Job.

   Penting

   Nilai variabel baru hanya berlaku untuk penyebaran tertentu yang akan dimulai. Nilai yang didefinisikan dalam draf SQL tetap tidak berubah.

   

Referensikan variabel dalam penyebaran JAR atau Python

Anda dapat menggunakan variabel sebagai parameter input dalam fungsi Main dari penyebaran JAR atau Python.

Buat variabel

1. Masuk ke konsol pengembangan Realtime Compute for Apache Flink. Temukan ruang kerja yang ingin dikelola dan klik Console di kolom Actions.

2. Di panel navigasi kiri, pilih Security > Variables. Di halaman Variabel, klik Add Variable.

   Parameter	Deskripsi
   Nama Variabel	Nama variabel harus unik dalam namespace yang sama dan tidak dapat diubah setelah variabel dibuat.
   Nilai Variabel	Nilai variabel bersifat case-sensitive. Perhatikan huruf besar/kecil saat memasukkan huruf dalam nilai variabel. Anda dapat mengubah nilai variabel setelah dibuat. Untuk informasi lebih lanjut, lihat bagian Edit atau hapus variabel dalam topik ini.
   Tipe	Anda tidak dapat mengubah tipe variabel setelah dibuat. Nilai valid: Teks biasa: Anda dapat langsung melihat nilai variabel di halaman Variabel. Teks terenkripsi: Anda tidak dapat melihat nilai variabel.

3. Klik OK.

Referensikan variabel

Setelah membuat variabel, Anda dapat mereferensikan variabel dalam format ${secret_values.Nama variabel}. Bagian berikut memberikan contoh untuk mereferensikan variabel dalam berbagai skenario.

create temporary table `${secret_values.source_name}`(
    id varchar,
    name varchar
) with (
    'connector' = 'datagen'
);


create temporary table blackhole(
    id varchar,
    `${secret_values.test_name}` varchar
) with (
    'connector' = '${secret_values.blackhole}'
);

insert into blackhole select * from `${secret_values.source_name}`;

source:
  type: mysql
  name: Sumber MySQL
  hostname: localhost
  port: 3306
  username: test
  password: ${secret_values.mysqlpw}
  tables: app_db.\.*
  server-id: 5400-5404

···

USE CATALOG paimon;

CREATE DATABASE IF NOT EXISTS `${secret_values.test_name}`;

CREATE TABLE paimon.`${secret_values.test_name}`.ods_user_log
(
    item_id  int NOT NULL,
    `${secret_values.user}` varchar(50) NOT NULL,
    action  varchar(20)  NOT NULL,
    vtime   timestamp,
    ds      varchar(10) NOT NULL
)
PARTITIONED BY (ds);

SELECT * from paimon.`${secret_values.test_name}`.ods_user_log LIMIT 10;

Edit atau hapus variabel

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

2. Di panel navigasi kiri, pilih Security > Variables. Di halaman Variabel, temukan variabel yang ingin diedit atau dihapus dan klik Edit atau Delete di kolom Actions.

   • Edit Variabel

     Anda dapat mengubah nilai variabel. Hanya anggota dengan izin editor atau lebih tinggi yang dapat mengedit variabel.

   • Hapus Variabel

     Hanya anggota dengan izin editor atau lebih tinggi, atau anggota dengan izin penghapusan variabel yang dapat menghapus variabel.