python - 使用 Apache airflow 存储和访问密码

Question

我们使用 Airflow 作为调度器。我想在 DAG 中调用一个简单的 bash 运算符。 bash 脚本需要密码作为参数才能进行进一步处理。

如何在 Airflow (config/variables/connection) 中安全地存储密码并在 dag 定义文件中访问它？

我是 Airflow 和 Python 的新手，因此不胜感激。

Answer 1

您可以将密码存储在 Hook 中 - 只要您设置了 fernet key ，密码就会被加密。

以下是如何通过 UI 创建连接:

然后:

要访问此密码:

from airflow.hooks.base_hook import BaseHook  # Deprecated in Airflow 2

connection = BaseHook.get_connection("username_connection")
password = connection.password # This is a getter that returns the unencrypted password.

Airflow 2 发布以来的更新

库 airflow.hooks.base_hook has been deprecated你必须使用 airflow.hooks.base相反。