This module contains Google Pub/Sub links.
Module Contents
Attributes
-
airflow.providers.google.cloud.links.pubsub.PUBSUB_BASE_LINK = '/cloudpubsub'[source]
-
airflow.providers.google.cloud.links.pubsub.PUBSUB_TOPIC_LINK[source]
-
airflow.providers.google.cloud.links.pubsub.PUBSUB_SUBSCRIPTION_LINK[source]
-
class airflow.providers.google.cloud.links.pubsub.PubSubTopicLink[source]
Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink
Helper class for constructing Pub/Sub Topic Link
-
name = 'Pub/Sub Topic'[source]
-
key = 'pubsub_topic'[source]
-
format_str[source]
-
static persist(context, task_instance, topic_id, project_id)[source]
-
class airflow.providers.google.cloud.links.pubsub.PubSubSubscriptionLink[source]
Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink
Helper class for constructing Pub/Sub Subscription Link
-
name = 'Pub/Sub Subscription'[source]
-
key = 'pubsub_subscription'[source]
-
format_str[source]
-
static persist(context, task_instance, subscription_id, project_id)[source]
