如何检索Python中所有气流DAG的列表？

发布于 2025-01-22 14:44:51 字数 76 浏览 2 评论 0 原文

有CLI函数气流DAGS LIST ，它列出了当前环境中的所有DAG。 Python API中是否有类似的功能？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

那请放手 2025-01-29 14:44:51

是的。气流REST API具有端点。

GET /dags

还有官方 python client api，以便您可以轻松地与python一起使用。
您可以看到 get_dags ：

with client.ApiClient(configuration) as api_client:
    # Create an instance of the API class
    api_instance = dag_api.DAGApi(api_client)
    limit = 100
    offset = 0
    order_by = "order_by_example"
    tags = [
        "tags_example",
    ]
    only_active = True
    try:
        # List DAGs
        api_response = api_instance.get_dags(limit=limit, offset=offset, order_by=order_by, tags=tags, only_active=only_active)
        pprint(api_response)
    except client.ApiException as e:
        print("Exception when calling DAGApi->get_dags: %s\n" % e)

Yes. Airflow Rest API has List DAGs endpoint.

GET /dags

There is also official Python client for the API so you can use it with Python easily.
You can see example how to set it for get_dags:

with client.ApiClient(configuration) as api_client:
    # Create an instance of the API class
    api_instance = dag_api.DAGApi(api_client)
    limit = 100
    offset = 0
    order_by = "order_by_example"
    tags = [
        "tags_example",
    ]
    only_active = True
    try:
        # List DAGs
        api_response = api_instance.get_dags(limit=limit, offset=offset, order_by=order_by, tags=tags, only_active=only_active)
        pprint(api_response)
    except client.ApiException as e:
        print("Exception when calling DAGApi->get_dags: %s\n" % e)

回复收藏 0 原文

~没有更多了~