如何通过编程方式更新并保存Airflow连接中的密码

要让修改后的Airflow连接密码持久化到元数据库，核心是通过Airflow的SQLAlchemy ORM会话提交修改，或者用官方CLI工具完成更新，以下是具体实现方式：

方法一：通过Python代码直接操作ORM模型 #

Airflow的Connection类本身是SQLAlchemy模型，结合Airflow提供的会话管理工具，就能把修改同步到数据库：

from airflow.models import Connection
from airflow.utils.session import create_session

def update_connection_password(conn_id, new_password):
    # 创建数据库会话上下文
    with create_session() as session:
        # 查询目标连接
        conn = session.query(Connection).filter(Connection.conn_id == conn_id).first()
        if not conn:
            print(f"未找到ID为 {conn_id} 的连接")
            return
        
        # 设置新密码（set_password会自动处理加密逻辑）
        conn.set_password(new_password)
        # 提交会话，将修改写入数据库
        session.commit()
        print(f"连接 {conn_id} 的密码已成功更新")

# 调用示例
update_connection_password("your_conn_id", "new_secure_password")

这里的关键是用create_session()获取Airflow的数据库会话，修改后提交会话——这一步才会把内存中的改动同步到元数据库，而不是仅停留在内存层面。

方法二：使用Airflow CLI命令（适合脚本/批量操作） #

如果更倾向于用命令行方式更新，Airflow 2.x及以上版本支持用airflow connections add命令结合--update参数来覆盖已有连接的密码：

airflow connections add your_conn_id --conn-password 'your_new_password' --update

这个命令会直接修改元数据库中对应连接的密码字段，无需手动处理会话或ORM操作。

注意事项 #

• 执行代码/命令的用户或进程需要拥有Airflow元数据库的读写权限
• set_password()方法会自动适配Airflow的密码加密配置（如果启用了fernet_key），不需要手动加密密码
• 如果你使用的是Airflow 1.x，核心逻辑一致，但会话管理可能需要用sqlalchemy.orm.session.Session手动创建，而非create_session()工具函数

内容的提问来源于stack exchange，提问作者karlk