| :py:mod:`airflow.providers.google.cloud.links.pubsub` |
| ===================================================== |
| |
| .. py:module:: airflow.providers.google.cloud.links.pubsub |
| |
| .. autoapi-nested-parse:: |
| |
| This module contains Google Pub/Sub links. |
| |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.google.cloud.links.pubsub.PubSubTopicLink |
| airflow.providers.google.cloud.links.pubsub.PubSubSubscriptionLink |
| |
| |
| |
| |
| Attributes |
| ~~~~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.google.cloud.links.pubsub.PUBSUB_BASE_LINK |
| airflow.providers.google.cloud.links.pubsub.PUBSUB_TOPIC_LINK |
| airflow.providers.google.cloud.links.pubsub.PUBSUB_SUBSCRIPTION_LINK |
| |
| |
| .. py:data:: PUBSUB_BASE_LINK |
| :annotation: = https://console.cloud.google.com/cloudpubsub |
| |
| |
| |
| .. py:data:: PUBSUB_TOPIC_LINK |
| |
| |
| |
| |
| .. py:data:: PUBSUB_SUBSCRIPTION_LINK |
| |
| |
| |
| |
| .. py:class:: PubSubTopicLink |
| |
| Bases: :py:obj:`airflow.providers.google.cloud.links.base.BaseGoogleLink` |
| |
| Helper class for constructing Pub/Sub Topic Link |
| |
| .. py:attribute:: name |
| :annotation: = Pub/Sub Topic |
| |
| |
| |
| .. py:attribute:: key |
| :annotation: = pubsub_topic |
| |
| |
| |
| .. py:attribute:: format_str |
| |
| |
| |
| |
| .. py:method:: persist(context, task_instance, topic_id, project_id) |
| :staticmethod: |
| |
| |
| |
| .. py:class:: PubSubSubscriptionLink |
| |
| Bases: :py:obj:`airflow.providers.google.cloud.links.base.BaseGoogleLink` |
| |
| Helper class for constructing Pub/Sub Subscription Link |
| |
| .. py:attribute:: name |
| :annotation: = Pub/Sub Subscription |
| |
| |
| |
| .. py:attribute:: key |
| :annotation: = pubsub_subscription |
| |
| |
| |
| .. py:attribute:: format_str |
| |
| |
| |
| |
| .. py:method:: persist(context, task_instance, subscription_id, project_id) |
| :staticmethod: |
| |
| |
| |
