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

此模块包含 Google Cloud Tasks 链接。

模块内容¶

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

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

airflow.providers.google.cloud.links.cloud_tasks.CLOUD_TASKS_QUEUE_LINK[源码]¶

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

基类: airflow.providers.google.cloud.links.base.BaseGoogleLink

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

static extract_parts(queue_name)[源码]¶

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

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

static persist(operator_instance, context, queue_name)[源码]¶

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

基类: airflow.providers.google.cloud.links.base.BaseGoogleLink

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

static persist(operator_instance, context, project_id)[源码]¶