示例 Airflow DAG,用于在 Google Cloud 中创建和删除队列,以及在 Google Cloud Tasks 服务中创建、获取、列出、运行和删除任务。
模块内容
属性
-
tests.system.google.cloud.tasks.example_tasks.ENV_ID[source]
-
tests.system.google.cloud.tasks.example_tasks.DAG_ID = 'cloud_tasks_tasks'[source]
-
tests.system.google.cloud.tasks.example_tasks.timestamp[source]
-
tests.system.google.cloud.tasks.example_tasks.LOCATION = 'us-central1'[source]
-
tests.system.google.cloud.tasks.example_tasks.QUEUE_ID[source]
-
tests.system.google.cloud.tasks.example_tasks.TASK_NAME = 'task-to-run'[source]
-
tests.system.google.cloud.tasks.example_tasks.TASK[source]
-
tests.system.google.cloud.tasks.example_tasks.generate_random_string()[source]
为队列和任务名称生成随机字符串。队列名称在过去 7 天内不能重复,任务名称在过去 1 小时内不能重复。
-
tests.system.google.cloud.tasks.example_tasks.test_run[source]