在 airflow.cfg 文件中是可以定义自己的变量的,比如说我们需要定义一下 Impala 数据连接的相关信息,就可以在 airflow.cfg 文件中进行定义,从而在脚本中进行使用。
1. 添加自定义配置信息
在 airflow.cfg 文件末尾添加:
[impala]host = 1.1.1.1port = 20000user = yumingminpassword = yumingminauth_mechanism = PLAIN
2. Python脚本中进行使用
import osimport airflowprint(airflow.configuration.get("impala", "user")) # yumingmin
注意:如果需要在调度中使用自定义变量,则需要重启 AirFlow,且一定要关闭 server-logs 服务。
版权声明
本站仅做备份收录,仅供研究与教学参考之用。
读者将信息用于其他用途的,全部法律及连带责任由读者自行承担,本站不承担任何责任。


评论