airflow.providers.google.cloud.example_dags.example_pubsub

Example Airflow DAG that uses Google PubSub services.

Module Contents

airflow.providers.google.cloud.example_dags.example_pubsub.START_DATE[source]
airflow.providers.google.cloud.example_dags.example_pubsub.GCP_PROJECT_ID[source]
airflow.providers.google.cloud.example_dags.example_pubsub.TOPIC_FOR_SENSOR_DAG[source]
airflow.providers.google.cloud.example_dags.example_pubsub.TOPIC_FOR_OPERATOR_DAG[source]
airflow.providers.google.cloud.example_dags.example_pubsub.MESSAGE[source]
airflow.providers.google.cloud.example_dags.example_pubsub.echo_cmd = Multiline-String[source]
Show Value
1{% for m in task_instance.xcom_pull('pull_messages') %}
2    echo "AckID: {{ m.get('ackId') }}, Base64-Encoded: {{ m.get('message') }}"
3{% endfor %}
airflow.providers.google.cloud.example_dags.example_pubsub.create_topic1[source]
airflow.providers.google.cloud.example_dags.example_pubsub.create_topic2[source]

Was this entry helpful?