AWS MWAA（托管 Apache Airflow）；以编程方式启用 DAG

AWS MWAA (Managed Apache Airflow); Programmatically enable DAGs

我们正在使用 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 状态？

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

您可以在DAG contractor中设置is_paused_upon_creation=False。

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

另一种选择是通过 unpause CLI:

airflow dags unpause [-h] [-S SUBDIR] dag_id