tests.system.google.cloud.pubsub.example_pubsub

Example Airflow DAG that uses Google PubSub services.

Attributes

ENV_ID

PROJECT_ID

DAG_ID

TOPIC_ID

MESSAGE

MESSAGE_TWO

echo_cmd

create_topic

test_run

Module Contents

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]
Show Value
"""
{% 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]

Was this entry helpful?