Realtime Compute for Apache Flink:変数の管理

方法 1：エントリポイント引数内で名前空間変数を参照

1. 左側ナビゲーションウィンドウで、セキュリティ > 変数 を選択し、名前空間変数を作成します。

2. O&M > デプロイメント を選択し、デプロイメントの作成 をクリックします。

3. エントリポイント Main 引数 フィールドに、以下の形式で変数名を入力します。

   コンソールで変数を管理するには、[セキュリティ] > [変数] へ移動します。変数名に特殊文字が含まれている場合は、エントリポイントのメイン引数パラメーターの値に特殊文字を指定したい場合はどうすればよいですか？

   --<コード内の変数名> ${secret_values.<コンソール上の変数名>}

   例：--akid ${secret_values.test1}

   

4. デプロイ をクリックします。

5. 対象のデプロイメントを見つけ、操作 列の 開始 をクリックします。

方法 2：デプロイメントダイアログ内で変数をインライン定義

1. 左側ナビゲーションウィンドウで、O&M > デプロイメント を選択し、デプロイメントの作成 をクリックします。

2. ダイアログボックスで、エントリポイント Main 引数 フィールドに変数名を入力し、変数 セクションに変数の値を入力します。変数名に特殊文字が含まれる場合は、「エントリポイント Main 引数パラメーターの値に特殊文字を指定したい場合の対応方法」をご参照ください。その他のデプロイメントパラメーターについては、「デプロイメントの作成」をご参照ください。

   

3. デプロイ をクリックします。

4. O&M > デプロイメント を選択します。対象のデプロイメントを見つけ、操作 列の 開始 をクリックします。ジョブの開始 パネルで、必要に応じてこのジョブ開始時の変数値を更新します。

   

SQL ドラフト

SQL ドラフトの DDL 文で、${secret_values.変数名} の形式を使用します。以下のルールに従ってください。

• WITH 句内の変数：シングルクォートで囲む — '${secret_values.変数名}'

• テーブル名またはフィールド名として使用する変数：バックティックで囲む — ` ${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}`;

データインジェスト

認証情報を平文で保存しないために、YAML 形式のデータインジェスト構成内で変数を参照します。例：

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;