tests.system.google.cloud.tasks.example_queue

示例 Airflow DAG,用於在 Google Cloud 的 Google Cloud Tasks 服務中建立、獲取、列出、更新、清除、暫停、恢復和刪除佇列。

所需設定: - GCP_APP_ENGINE_LOCATION:GCP 專案的 App Engine 位置 gcloud app describe | grep locationId

屬性

ENV_ID

DAG_ID

LOCATION

QUEUE_ID

test_run

函式

generate_random_string()

為佇列和任務名稱生成隨機字串。

模組內容

tests.system.google.cloud.tasks.example_queue.ENV_ID[source]
tests.system.google.cloud.tasks.example_queue.DAG_ID = 'cloud_tasks_queue'[source]
tests.system.google.cloud.tasks.example_queue.LOCATION[source]
tests.system.google.cloud.tasks.example_queue.QUEUE_ID = ''[source]
tests.system.google.cloud.tasks.example_queue.generate_random_string()[source]

為佇列和任務名稱生成隨機字串。佇列名稱在過去 7 天內不能重複,任務名稱在過去 1 小時內不能重複。

tests.system.google.cloud.tasks.example_queue.test_run[source]

此條目有幫助嗎?