在Airflow上运行时,可以通过配置密钥,来保护敏感数据。FERNET_KEY是Airflow使用的加密密钥。如果你在升级Airflow版本时,出现了'airflow upgrade_check”检查失败的问题,或者想要查看现有的FERNET_KEY是否仍然适合使用,需要按照以下步骤:
python -c "from cryptography.fernet import Fernet; print(Fernet.generate_key().decode())"
python -c "from cryptography.fernet import Fernet; print(Fernet.generate_key().decode())"
以下是一个示例,展示如何在Airflow中获取或设置FERNET_KEY:
from cryptography.fernet import Fernet
FERNET_KEY = b'EPuGRXoc-lQnzXXu6YHrmH7KITOh3FjSPmeDrszxBK4='
cipher_suite = Fernet(FERNET_KEY) cipher_text = cipher_suite.encrypt(b'my_secret_message')
plain_text = cipher_suite.decrypt(cipher_text)
print(plain_text)