在Airflow中,连接密码通常存储在airflow.cfg
配置文件中的[core]
部分。默认情况下,密码是以明文形式存储的。如果你想加密密码以提高安全性,可以使用以下方法:
方法一:使用Airflow内置的安全机制
airflow.cfg
文件。[core]
部分中找到fernet_key
参数。from cryptography.fernet import Fernet
fernet_key = Fernet.generate_key()
fernet_key
参数中。airflow.cfg
文件。方法二:使用环境变量
AIRFLOW__CORE__FERNET_KEY
的环境变量,并将其值设置为Fernet key。无论使用哪种方法,当需要使用连接密码时,可以使用以下代码解密密码:
from airflow import settings
from airflow.models import Connection
from cryptography.fernet import Fernet
# 获取Fernet key
fernet_key = settings.get('fernet_key')
# 创建Fernet对象
fernet = Fernet(fernet_key)
# 获取连接密码
connection = Connection.get_connection_by_uri('your_connection_uri')
password = connection.password
# 解密密码
decrypted_password = fernet.decrypt(password.encode()).decode()
# 打印解密后的密码
print(decrypted_password)
上述代码假设你已经正确配置了Airflow的路径和连接URI。在代码中,我们首先从Airflow的配置中获取Fernet key,然后使用该密钥创建一个Fernet对象。接下来,我们获取连接对象并从中提取密码。最后,使用Fernet对象解密密码,并打印出解密后的密码。
请注意,使用方法一或方法二,解密密码的代码示例都是相同的。只需确保在解密密码之前正确配置了Fernet key。