tests.system.google.cloud.pubsub.example_pubsub_deferrable¶

使用 Google Pub/Sub 服务的 Apache Airflow DAG 示例。

属性¶

`ENV_ID`
`PROJECT_ID`
`DAG_ID`
`TOPIC_ID`
`MESSAGE`
`create_topic`
`test_run`

模块内容¶

tests.system.google.cloud.pubsub.example_pubsub_deferrable.ENV_ID[source]¶

tests.system.google.cloud.pubsub.example_pubsub_deferrable.PROJECT_ID[source]¶

tests.system.google.cloud.pubsub.example_pubsub_deferrable.DAG_ID = 'pubsub_async'[source]¶

tests.system.google.cloud.pubsub.example_pubsub_deferrable.TOPIC_ID = 'topic-pubsub_async-Uninferable'[source]¶

tests.system.google.cloud.pubsub.example_pubsub_deferrable.MESSAGE[source]¶

tests.system.google.cloud.pubsub.example_pubsub_deferrable.create_topic[source]¶

tests.system.google.cloud.pubsub.example_pubsub_deferrable.test_run[source]¶

本条目有帮助吗？