可以通过更改Airflow配置文件中的“airflow__core__variable_value_mask”选项来解决此问题。例如,在“airflow.cfg”文件中,将该选项更改为以下内容:
airflow__core__variable_value_mask =*****
然后,在代码中使用变量时,将值作为密钥传递到“Variable.get”函数中,以解密该值。示例代码如下:
from airflow.models import Variable
my_variable = Variable.get("my_variable", deserialize_json=False, default_var=None)
print(my_variable)