Realtime Compute for Apache Flink:Kelola variabel

Rujuk variabel dalam SQL draft

Gunakan variabel dalam SQL draft untuk menghindari hardcoding nilai—misalnya, sebagai parameter input untuk fungsi kustom. Setelah deployment dimulai, Anda dapat memperbarui nilai variabel tanpa mengubah draft tersebut.

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

2. Di editor SQL, definisikan variabel dalam format ${Variable name}. Ikuti aturan berikut:

   • Variabel dalam klausa WITH: bungkus dengan tanda kutip tunggal — '${Variable name}'

   • Variabel sebagai nama tabel atau nama field: bungkus dengan tanda backtick — ` ${Variable name} `

   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 mendeteksi variabel dalam draft tersebut. Tetapkan nilainya dengan salah satu metode berikut:

   • Panel Variables: masukkan nilai langsung di panel Variables pada editor SQL.

   • Tab Configurations: Klik tab Configurations di sisi kanan SQL Editor, lalu masukkan nilai pada bagian Variables.

4. Setelah menerapkan draft, verifikasi variabel yang dirujuk di tab Configuration pada halaman Deployments.

   

5. Di halaman Deployments, temukan deployment target dan klik Start di kolom Actions. Di panel Start Job, perbarui nilai variabel sesuai kebutuhan.

   Penting

   Nilai yang diperbarui hanya berlaku untuk job start kali ini. Nilai yang ditentukan dalam SQL draft tetap tidak berubah.

   

Rujuk variabel dalam deployment JAR atau Python

Gunakan deployment variable sebagai argumen entry point dalam fungsi Main pada deployment JAR atau Python. Tersedia dua metode.

Buat variabel

Hanya anggota dengan izin editor atau lebih tinggi, atau anggota yang memiliki izin pembuatan variabel, yang dapat membuat variabel.

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

2. Di panel navigasi sebelah kiri, pilih Security > Variables, lalu klik Add Variable dan konfigurasikan parameter berikut:

   Parameter	Description
   Variable name	Harus unik dalam namespace. Tidak dapat diubah setelah dibuat.
   Variable value	Case-sensitive. Dapat diperbarui setelah dibuat. Untuk detailnya, lihat Edit or delete a variable.
   Type	Tidak dapat diubah setelah dibuat. Plaintext: nilainya terlihat di halaman Variables. Ciphertext: nilainya disembunyikan.

3. Klik OK.

Rujuk variabel

Setelah membuat variabel, rujuk variabel tersebut dalam format ${secret_values.Variable name}. Contoh berikut menunjukkan cara merujuk namespace variable 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: Mysql Source
  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 dan klik Console di kolom Actions.

2. Di panel navigasi sebelah kiri, pilih Security > Variables. Temukan variabel target dan klik Edit atau Delete di kolom Actions.

   • Edit: ubah nilai variabel. Hanya anggota dengan izin editor atau lebih tinggi yang dapat mengedit variabel.

   • Delete: hapus variabel. Hanya anggota dengan izin editor atau lebih tinggi, atau anggota yang memiliki izin penghapusan variabel, yang dapat menghapus variabel.