在Airflow中连接MySQL数据库时,可以在“airflow.cfg”文件中配置数据库连接信息,如下所示:
[mysql]
host = localhost
port = 3306
user = airflow
password = your_password
database = airflow
如果在UI界面连接数据库时忘记密码,可以通过以下步骤找回:
如果您的密码被加密,您可以使用以下命令生成新的密码并在配置文件中将其更新:
>>> from cryptography.fernet import Fernet
>>> f = Fernet.generate_key()
>>> print(f.decode())
new_key_here
>>> f = Fernet(b'new_key_here')
>>> password = b'your_password'
>>> encrypted_password = f.encrypt(password)
>>> print(encrypted_password.decode())
your_encrypted_password_here
然后,将新的加密密码更新到“airflow.cfg”文件中的“[mysql]”部分,如下所示:
[mysql]
host = localhost
port = 3306
user = airflow
password = your_encrypted_password_here
database = airflow
重新启动Airflow服务后,您应该能够在UI中连接到数据库。
上一篇:airflow.providers和airflow.contrib的区别
下一篇:Airflow/AmazonEMR:VPC/subnet配置无效:子网是必需的:指定的实例类型m5.xlarge只能在VPC中使用。