我们正在使用 AWS MWAA。我们以编程方式将 DAG.py 文件添加到我们的 S3 存储桶中。然后它们显示在 UI 中。但是,它们是“OFF”的,您必须单击“ON”按钮才能启动它们。
编辑:此外,我们有时可能希望将打开的 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 已经存在,这个标志将被忽略。
您可以is_paused_upon_creation=False
在 DAG 承包商中进行设置。
dag = DAG(
dag_id='tutorial',
default_args=default_args,
is_paused_upon_creation=False,
)
另一种选择是通过取消暂停 CLI来完成:
airflow dags unpause [-h] [-S SUBDIR] dag_id
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句