是否可以使用 Cloud Composer 的 Python 客户端触发 DAG？
Is it possible to trigger a DAG using the Python client for Cloud Composer?
我注意到可以通过发出
使用 gcloud 触发 DAG
gcloud composer environments run myenv trigger_dag -- some_dag --run_id=foo
据我了解，gcloud 使用客户端库来完成它所做的一切，因此我假设我可以使用 Python client for Cloud Composer. Unfortunately I've browsed through the documentation at that link, specifically at https://googleapis.dev/python/composer/latest/service_v1beta1/environments.html 执行相同的操作（即触发作曲家 DAG），并且我看不到任何东西可以让我做与 gcloud composer environments run.
相同的事情
请有人帮忙解释是否可以使用 Cloud Composer 的 Python 客户端触发 DAG？
很遗憾，Cloud Composer 的 Python 客户端库目前不支持 DAG 触发器。通过 Python 触发它的一种可能的解决方法是将 HTTP 请求直接发送到 Cloud Composer 中的气流实例。参见 Trigger a DAG from Cloud Functions for more details. See Python code that triggers the DAG hosted in Cloud Function。
在本文档中，Cloud Function 配置为在将新文件上传到存储桶时触发 DAG。如果这不适合您的用例，您可以随时更改适合您的用例的 Cloud Functions 的触发器类型。
我注意到可以通过发出
使用 gcloud 触发 DAGgcloud composer environments run myenv trigger_dag -- some_dag --run_id=foo
据我了解，gcloud 使用客户端库来完成它所做的一切，因此我假设我可以使用 Python client for Cloud Composer. Unfortunately I've browsed through the documentation at that link, specifically at https://googleapis.dev/python/composer/latest/service_v1beta1/environments.html 执行相同的操作（即触发作曲家 DAG），并且我看不到任何东西可以让我做与 gcloud composer environments run.
请有人帮忙解释是否可以使用 Cloud Composer 的 Python 客户端触发 DAG？
很遗憾，Cloud Composer 的 Python 客户端库目前不支持 DAG 触发器。通过 Python 触发它的一种可能的解决方法是将 HTTP 请求直接发送到 Cloud Composer 中的气流实例。参见 Trigger a DAG from Cloud Functions for more details. See Python code that triggers the DAG hosted in Cloud Function。
在本文档中，Cloud Function 配置为在将新文件上传到存储桶时触发 DAG。如果这不适合您的用例，您可以随时更改适合您的用例的 Cloud Functions 的触发器类型。