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

此条目有帮助吗？