Realtime Compute for Apache Flink:Değişken yönetimi

ETL (SQL işi)

SQL işi geliştirme sırasında, özel işlevler için bağımsız değişkenler dahil olmak üzere değişkenleri kullanabilirsiniz. İşi başlatırken değişken değerlerini de değiştirebilirsiniz.

1. Realtime Compute for Apache Flink konsolunun sol gezinme bölmesinde, şuraya gidin: Development > ETL.

2. Hedef SQL işinizin SQL düzenleyicisinde, aşağıdaki örnekte gösterildiği gibi ${variable_name} formatını kullanarak değişkenler oluşturun.

   • WITH yan tümcesinde bir parametre olarak kullanıldığında, değişkeni tek tırnak içine alın: '${variable_name}'.

   • Diğer konumlarda (örneğin SQL tablo veya alan adları için) kullanıldığında, değişkeni geri tırnak içine alın: ${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. Flink, SQL işinde bu formatı kullanan dağıtım değişkenlerini otomatik olarak tanımlar. Bu değişkenler için değer girmeniz gerekir.

   • Yöntem 1: SQL düzenleyicide Job Variables paneli görünür. Değerleri bu panele girin.

     Job Variables panelinde anahtar-değer çiftlerini yapılandırın: source_name=datagen, test_name=name ve blackhole=blackhole.

   • Yöntem 2: Sağ taraftaki More Configurations seçeneğine tıklayın. Değerleri Job Variables bölümüne girin.

     Örneğin, source_name değişkenini datagen olarak, test_name değişkenini name olarak ve blackhole değişkenini blackhole olarak yapılandırın. Ardından, bu değerlere SQL kodunuzda ${variable_name} sözdizimini kullanarak başvurabilirsiniz.

4. İş dağıtıldıktan sonra, işin ayrıntılar sayfasındaki Deployments sekmesi altında Deployment Details sekmesinden değişkenlerini görüntüleyebilirsiniz.

   İş özelliklerinde, Job Variables satırı yapılandırılmış değişkenleri (örneğin source_name, test_name ve blackhole) ve bunlara karşılık gelen değerleri gösterir.

5. Hedef işin Actions sütununda Start seçeneğine tıklayın. İş başlatma panelinde değişken değerlerini değiştirebilirsiniz.

   Önemli

   İş başlatma panelinde yapılan değişken değeri değişiklikleri yalnızca mevcut iş çalıştırmasına uygulanır. SQL işinde tanımlanan değerleri değiştirmez.

   İş başlatma panelinde stateless start veya stateful start modunu seçebilirsiniz. Stateful start'i seçerseniz, Recover from latest state gibi kurtarma seçeneklerini yapılandırabilirsiniz. Job Variables bölümü, source_name için datagen, test_name için name ve blackhole için blackhole gibi değişkenleri ve varsayılan değerlerini görüntüler. Bunları gerektiği gibi değiştirebilir ve ardından Start seçeneğine tıklayabilirsiniz.

JAR/Python dağıtımı

JAR/Python dağıtımlarında ana işlev için bağımsız değişken olarak değişkenleri kullanabilirsiniz.

Değişken oluşturma

1. Realtime Compute for Apache Flink konsoluna giriş yapın. Hedef çalışma alanını bulun ve Actions sütununda Console seçeneğine tıklayın.

2. Sol gezinme bölmesinde, şuraya gidin: Security > Variables ve Add Variable seçeneğine tıklayın.

   Parametre	Açıklama
   Değişken Adı	Değişken adı, ad alanı içinde benzersiz olmalı ve oluşturulduktan sonra değiştirilememelidir.
   Değişken Değeri	Değişken değerleri büyük/küçük harfe duyarlıdır. Değer, oluşturulduktan sonra değiştirilebilir. Ayrıntılar için bkz. Değişkeni düzenleme veya silme.
   Tür (Düz Metin/Şifreli Metin)	Tür, oluşturulduktan sonra değiştirilemez. Düz Metin: Değişken değeri Variables sayfasında doğrudan görünür. Şifreli Metin: Değişken değeri gizlidir. Değişken oluşturulduktan sonra, Variables sayfasındaki listede adını, türünü, değerini ve oluşturulma zamanını görüntüleyebilirsiniz. Ayrıca değişkeni Edit veya Delete edebilirsiniz.

3. OK seçeneğine tıklayın.

Değişken kullanma

Bir değişken oluşturduktan sonra, bunu ${secret_values.variable_name} formatını kullanarak başvurabilirsiniz. "variable_name" yerine kendi değişkeninizin adını yazın.

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;

Değişkeni düzenleme veya silme

1. Realtime Compute for Apache Flink konsoluna giriş yapın. Hedef çalışma alanını bulun ve Actions sütununda Console seçeneğine tıklayın.

2. Sol gezinme bölmesinde, şuraya gidin: Security > Variables. Hedef değişkeni bulun ve Actions sütununda Edit veya Delete seçeneğine tıklayın.

   • Düzenle

     Bir değişkenin değerini değiştirebilirsiniz. Yalnızca düzenleyici veya daha yüksek izinlere sahip üyeler değişkenleri düzenleyebilir.

   • Sil

     Yalnızca düzenleyici veya daha yüksek izinlere sahip üyeler ya da değişken silme iznine sahip özel üyeler değişkenleri silebilir.