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]¶