您可以直接在 Airflow Dag 中创建变量吗

Question

据我了解，常见的 Airflow 工作流是在 UI 中创建一个变量，并根据需要在 dag 中访问它。如果由于某种原因你需要更新这个变量，你可以简单地 Variable.set("foo", bar).

有什么方法可以在 dag 中创建新变量吗？

伪：

def create_new_client_config(client_name):
    data = get_client_details(client_name)
    client_config = Variable.create(f"{client_name}", data)
    client_config.save()

谢谢！

Answer 1

Variable.set("my_key", "my_value") 也用于创建变量（不仅用于更新）