Realtime Compute for Apache Flink:Gerenciar variáveis

Referenciar uma variável em um rascunho SQL

Durante o desenvolvimento de um rascunho SQL, utilize variáveis. Elas podem servir, por exemplo, como parâmetros de entrada para funções personalizadas. Além disso, modifique os valores das variáveis após o início da implantação do rascunho.

1. No painel de navegação à esquerda do console do Realtime Compute for Apache Flink, escolha Development > ETL.

2. No editor SQL do rascunho desejado, crie variáveis no formato ${Nome da variável}. O código de exemplo abaixo ilustra essa criação.

   • Ao referenciar uma variável na cláusula WITH, envolva-a com aspas simples ('), seguindo o formato '${Nome da variável}'.

   • Para referenciar uma variável como nome de tabela ou campo em uma instrução SQL, utilize crases (), no formato ${Nome da variável}`.

   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. O Realtime Compute for Apache Flink identifica automaticamente as variáveis no formato exigido dentro do rascunho. Configure os valores das variáveis utilizando um dos métodos abaixo:

   • Método 1: insira o valor da variável no painel Variables do editor SQL.

     

   • Método 2: clique em Configurations no lado direito do editor SQL. No painel Configurations, defina os valores na seção Variables.

     

4. Após implantar o rascunho, visualize a variável referenciada na aba Configuration da página Deployments.

   

5. Na página Deployments, localize a implantação que deseja iniciar e clique em Start na coluna Actions. Altere o valor da variável no painel Start Job.

   Importante

   Os novos valores das variáveis terão efeito apenas nesta execução específica da implantação. As definições originais no rascunho SQL permanecem inalteradas.

   

Referenciar uma variável em uma implantação JAR ou Python

Utilize variáveis como parâmetros de entrada na função Main de implantações JAR ou Python.

Criar uma variável

1. Faça login no console de desenvolvimento do Realtime Compute for Apache Flink. Localize o workspace que deseja gerenciar e clique em Console na coluna Actions.

2. No painel de navegação à esquerda, escolha Security > Variables. Na página Variables, clique em Add Variable.

   Parâmetro	Descrição
   Variable Name	Os nomes das variáveis devem ser únicos dentro do mesmo namespace e não podem ser alterados após a criação.
   Variable Value	Os valores das variáveis diferenciam maiúsculas de minúsculas. Atenção ao digitar letras no valor. Modifique o valor de uma variável após sua criação. Para mais detalhes, consulte a seção Editar ou excluir uma variável neste tópico.
   Type	O tipo da variável não pode ser modificado após a criação. Valores válidos: Texto simples: permite visualizar diretamente o valor da variável na página Variables. Texto cifrado: impede a visualização do valor da variável.

3. Clique em OK.

Referenciar uma variável

Após criar uma variável, referencie-a usando o formato ${secret_values.Nome da variável}. A seguir, são apresentados exemplos de referência em diferentes cenários.

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;

Editar ou excluir uma variável

1. Faça login no console do Realtime Compute for Apache Flink. Encontre o workspace que deseja gerenciar e clique em Console na coluna Actions.

2. No painel de navegação à esquerda, selecione Security > Variables. Na página Variables, localize a variável que deseja editar ou excluir e clique em Edit ou Delete na coluna Actions.

   • Editar uma variável

     Altere o valor de uma variável. Apenas membros com permissão de editor ou superior podem editar variáveis.

   • Excluir uma variável

     Apenas membros com permissão de editor ou superior, ou aqueles com permissão específica para exclusão, podem excluir variáveis.