使用 Google PubSub 服务的 Airflow DAG 示例。
模块内容
-
tests.system.google.cloud.pubsub.example_pubsub.ENV_ID[源代码]
-
tests.system.google.cloud.pubsub.example_pubsub.PROJECT_ID[源代码]
-
tests.system.google.cloud.pubsub.example_pubsub.DAG_ID = 'pubsub'[源代码]
-
tests.system.google.cloud.pubsub.example_pubsub.TOPIC_ID[源代码]
-
tests.system.google.cloud.pubsub.example_pubsub.MESSAGE[源代码]
-
tests.system.google.cloud.pubsub.example_pubsub.MESSAGE_TWO[源代码]
-
tests.system.google.cloud.pubsub.example_pubsub.echo_cmd = 多行字符串[源代码]
显示值
"""
{% 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[源代码]
-
tests.system.google.cloud.pubsub.example_pubsub.test_run[源代码]