示例 Airflow DAG，用于在 Google Cloud 中创建、获取、列出、更新、清除、暂停、恢复和删除 Google Cloud Tasks 服务中的队列。
必需设置：- GCP_APP_ENGINE_LOCATION：GCP 项目的 App Engine 位置 gcloud app describe | grep locationId。
模块内容
属性
-
tests.system.google.cloud.tasks.example_queue.ENV_ID[源代码]
-
tests.system.google.cloud.tasks.example_queue.DAG_ID = 'cloud_tasks_queue'[源代码]
-
tests.system.google.cloud.tasks.example_queue.LOCATION[源代码]
-
tests.system.google.cloud.tasks.example_queue.QUEUE_ID[源代码]
-
tests.system.google.cloud.tasks.example_queue.generate_random_string()[源代码]
为队列和任务名称生成随机字符串。队列名称在过去 7 天内不能重复，任务名称在过去 1 小时内不能重复。
-
tests.system.google.cloud.tasks.example_queue.test_run[源代码]