tests.system.google.cloud.pubsub.example_pubsub¶

使用 Google PubSub 服务的 Apache Airflow DAG 示例。

属性¶

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

模块内容¶

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

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

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

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

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

tests.system.google.cloud.pubsub.example_pubsub.MESSAGE_TWO[source]¶

tests.system.google.cloud.pubsub.example_pubsub.echo_cmd = Multiline-String[source]¶

显示值

"""
{% for m in task_instance.xcom_pull('pull_messages') %}
    echo "AckID: {{ m.get('ackId') }}, Base64-Encoded: {{ m.get('message') }}"
{% endfor %}
"""

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

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