使用 Google PubSub 服務的範例 Airflow DAG。
模組內容
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.ENV_ID[原始碼]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.PROJECT_ID[原始碼]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.DAG_ID = 'pubsub_async'[原始碼]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.TOPIC_ID[原始碼]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.MESSAGE[原始碼]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.create_topic[原始碼]
-
tests.system.google.cloud.pubsub.example_pubsub_deferrable.test_run[原始碼]