Realtime Compute for Apache Flink：變數管理

ETL（SQL作業）

支援在SQL作業開發中（包括自訂函數入參）使用變數，並在作業啟動時可再次修改變數值。

1. 單擊Flink開發控制台左側導覽列的資料開發 > ETL。

2. 在目標作業草稿的SQL編輯器中使用${變數名}格式建立變數，樣本如下。

   • 在WITH參數中使用時，需要使用單引號，'${變數名}'。

   • 在其他位置使用（例如SQL表名、欄位）時，需要使用反引號`${變數名}`。

   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. Flink會自動識別作業草稿中使用了該格式的作業變數，您需要填寫變數值。

   • 方法一：SQL編輯器會出現作業變數面板，可直接在面板中進行填寫。

     在作業變數面板中組態變數索引值對：source_name=datagen、test_name=name、blackhole=blackhole。

   • 方法二：單擊右側的更多配置，在作業變數地區進行填寫。

     例如，組態變數 source_name 為 datagen、test_name 為 name、blackhole 為 blackhole，SQL 中通過 ${variable_name} 文法引用對應變數值。

4. 作業部署後，您可以在作業營運頁面目標作業的部署詳情頁簽查看作業使用的變數。

   在作業屬性中，作業變數行展示了已配置的變數（如 source_name、test_name、blackhole）及其對應值。

5. 單擊目標作業操作列下的啟動。支援在作業啟動面板中修改變數值。

   重要

   作業啟動面板中修改變數值僅對作業本次啟動生效，不會修改SQL草稿中對應的變數值。

   在作業啟動面板中，可選擇無狀態啟動或有狀態啟動模式。選擇有狀態啟動時，可配置復原選項（如從最新狀態恢複）。作業變數地區展示變數名及其預設值，例如 source_name 對應 datagen、test_name 對應 name、blackhole 對應 blackhole，可按需修改後單擊啟動。

JAR/Python作業

支援JAR和Python作業中Main函數入參使用變數。

新增變數

1. 登入Realtime Compute管理主控台，單擊目標工作空間操作列下的控制台。

2. 在安全服務 > 變數管理頁面，單擊新增變數。

   參數	說明
   變數名	變數名需在同一個專案空間下保持唯一，建立後不支援修改。
   變數值	變數值對字母大小寫敏感，填寫時請注意字母大小寫。建立後支援修改變數值，詳情請參見編輯或刪除變數。
   類型（明文/密文）	建立後不支援修改類型。 明文：在變數管理頁面可以直接查看變數值。 密文：無法查看變數值。 變數建立成功後，在變數管理頁面的列表中可查看各變數的變數名、類型、變數值和建立時間，並可對變數進行編輯或刪除操作。

3. 單擊確定。

使用變數

增加變數後，您可以通過${secret_values.變數名}格式使用，使用時您僅需將其中的變數名進行修改，其他部分保留不變，具體樣本如下。

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;

編輯或刪除變數

1. 登入Realtime Compute管理主控台，單擊目標工作空間操作列下的控制台。

2. 在安全服務 > 變數管理頁面，單擊目標變數名操作列下編輯或刪除。

   • 編輯

     支援對變數值進行修改。僅editor及以上許可權成員支援編輯變數。

   • 刪除

     僅editor及以上許可權或具有刪除變數許可權的成員支援刪除變數。