docs-archive/apache-airflow-providers-google/8.4.0/_sources/_api/tests/system/providers/google/cloud/pubsub/example_pubsub/index.rst.txt

:py:mod:`tests.system.providers.google.cloud.pubsub.example_pubsub`
===================================================================

.. py:module:: tests.system.providers.google.cloud.pubsub.example_pubsub

.. autoapi-nested-parse::

   Example Airflow DAG that uses Google PubSub services.



Module Contents
---------------

.. py:data:: ENV_ID
   

   

.. py:data:: PROJECT_ID
   

   

.. py:data:: DAG_ID
   :annotation: = pubsub

   

.. py:data:: TOPIC_ID
   

   

.. py:data:: MESSAGE
   

   

.. py:data:: MESSAGE_TWO
   

   

.. py:data:: echo_cmd
   :annotation: = Multiline-String

    .. raw:: html

        <details><summary>Show Value</summary>

    .. code-block:: text
        :linenos:

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


    .. raw:: html

        </details>

   

.. py:data:: create_topic
   

   

.. py:data:: test_run