2

我们正在使用 AWS MWAA。我们以编程方式将 DAG.py 文件添加到 S3 存储桶中。然后它们会显示在 UI 中。但是，它们是“关闭”的，您必须单击“打开”按钮才能启动它们。

编辑：此外，我们有时可能想要将打开到关闭的 DAG（以编程方式）

我希望以编程方式执行此操作，但我无法弄清楚。

API 似乎没有： https ://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-actions-resources.html

Boto 似乎没有： https ://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/mwaa.html

是否可以通过 API 从 OFF/ON ON/OFF 操作 DAG 状态？

4

1 回答 1

3

这不能通过 API 实现，但您可以使用is_paused_upon_creation此标志指定第一次创建 dag 时是否暂停。如果 dag 已经存在，则此标志将被忽略。

您可以is_paused_upon_creation=False在 DAG 承包商中进行设置。

dag = DAG(
    dag_id='tutorial',
    default_args=default_args,
    is_paused_upon_creation=False,
)

另一种选择是通过unpause CLI来完成：

airflow dags unpause [-h] [-S SUBDIR] dag_id
于 2021-04-14T16:32:40.023 回答