Google Cloud Tasks¶

Cloud Tasks 是一項全受管服務，可讓您管理大量分散式任務的執行、分派和交付。透過使用 Cloud Tasks，您可以在使用者或服務對服務請求之外非同步地執行工作。

如需有關此服務的更多資訊，請造訪Cloud Tasks 產品文件

Google Cloud Tasks 空感測器¶

若要感測佇列是否為空，請使用 TaskQueueEmptySensor

airflow/providers/google/cloud/example_dags/example_cloud_task.py[原始碼]

gcp_cloud_tasks_sensor = TaskQueueEmptySensor(
    project_id=GCP_PROJECT_ID,
    location=GCP_ZONE,
    task_id="gcp_sense_cloud_tasks_empty",
    queue_name=QUEUE_NAME,
)