Flink 平台提供变量功能,支持您在 SQL 任务中创建默认的临时表或指定 InMemoryCatalog 创建表时,在 WITH 参数中直接引用变量并生效。使用变量能避免出现明文密钥、地址、资源名称等信息,提高安全性。
注意事项
- 变量仅支持在 SQL 任务中创建临时表(即 CREATE TEMPORARY TABLE),或指定 InMemoryCatalog 创建表时,在 WITH 参数中引用生效。
- 在 SQL 任务中引用变量时格式为
${secret_values.variable_name}
,其中secret_values.
为固定前缀,variable_name
为您创建的变量名称。 - 全局变量可以直接引用生效,但引用指定域变量需要在 Flink 参数配置中选择生效的变量作用域。系统将会先从您指定的变量作用域中查找变量,再从全局变量中查找变量,指定域变量优先级高于全局变量。如果变量不存在则运行报错。
创建变量
- 登录流式计算 Flink 版控制台。
- 在顶部菜单栏选择目标地域。
- 在左侧导航栏选择项目管理,然后单击项目区块进入项目。
- 在项目左侧导航栏选择任务开发 > Jupyter lab。
- 在变量页面,单击加号按钮,创建全局变量。
- 在新增变量对话框,选择创建全局变量或指定域变量,然后设置变量名称、变量值等参数,再单击确定。
创建全局变量。
配置 | 说明 |
---|
作用域 | 创建全局变量时,作用域选择全局。 |
目标文件夹 | 设置全局变量所属文件夹。 - 选择已有:在已经存在的文件夹中创建全局变量。系统默认存在一个文件夹,可以直接使用。
- 创建新的:手动输入一个新的文件夹名称,在新建文件夹中创建全局变量。
|
变量名称 | 自定义设置变量名称。 - 支持大小写字母、数字和短横线(-)组合,且必须以字母开头。
- 长度为 1~128 个字符。
- 名称必须在全局变量中唯一。
|
变量值 | 设置变量取值,以实际业务为准。 |
描述 | 当前变量的描述语句。 |
创建指定域变量。
配置 | 说明 |
---|
作用域 | 创建指定域变量时,作用域选择指定域。 |
目标域 | 设置指定域变量所属域,比如开发环境、测试环境、生产环境等域。 - 选择已有:在已经存在的域中创建变量。
指定域没有默认域,首次创建指定域时,必须选择创建新的域。 - 创建新的:手动输入一个新域名称,在新建域中创建全局变量。
|
变量名称 | 自定义设置变量名称。 - 支持大小写字母、数字和短横线(-)组合,且必须以字母开头。
- 长度为 1~128 个字符。
- 名称必须在所属域中唯一。
|
变量值 | 设置变量取值,以实际业务为准。 |
描述 | 当前变量的描述语句。 |
其他操作
- 查看变量详情:单击变量名称,即可查看变量详情。
- 删除变量:鼠标悬停在目标变量上,选择删除并进行二次确认。