airflow.providers.google.cloud.links.cloud_tasks¶

此模块包含 Google Cloud Tasks 链接。

属性¶

`CloudTasksQueueLink`	用于构建 Cloud Task Queue 链接的辅助类。
`CloudTasksLink`	用于构建 Cloud Task 链接的辅助类。

airflow.providers.google.cloud.links.cloud_tasks.CLOUD_TASKS_BASE_LINK = '/cloudtasks'[source]¶

airflow.providers.google.cloud.links.cloud_tasks.CLOUD_TASKS_QUEUE_LINK = '/cloudtasks/queue/{location}/{queue_id}/tasks?project={project_id}'[source]¶

airflow.providers.google.cloud.links.cloud_tasks.CLOUD_TASKS_LINK = '/cloudtasks?project={project_id}'[source]¶

class airflow.providers.google.cloud.links.cloud_tasks.CloudTasksQueueLink[source]¶

用于构建 Cloud Task Queue 链接的辅助类。

format_str = '/cloudtasks/queue/{location}/{queue_id}/tasks?project={project_id}'[source]¶

static extract_parts(queue_name)[source]¶

从队列名称中提取 project_id、location 和 queue id。

projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID。

static persist(operator_instance, context, queue_name)[source]¶

class airflow.providers.google.cloud.links.cloud_tasks.CloudTasksLink[source]¶

用于构建 Cloud Task 链接的辅助类。

static persist(operator_instance, context, project_id)[source]¶