Google Cloud Tasks¶
Cloud Tasks 是一項完全託管的服務,可用於管理大量分散式任務的執行、分派和交付。使用 Cloud Tasks,您可以在使用者或服務到服務請求之外非同步執行工作。
有關該服務的更多資訊,請訪問 Cloud Tasks 產品文件
Google Cloud Tasks Empty Sensor¶
要感知佇列為空,請使用 TaskQueueEmptySensor
tests/system/google/cloud/tasks/example_queue.py
queue_sensor = TaskQueueEmptySensor(
location=LOCATION,
task_id="queue_sensor",
queue_name=QUEUE_ID + "{{ task_instance.xcom_pull(task_ids='random_string') }}",
)