airflow.providers.google.cloud.links.pubsub

This module contains Google Pub/Sub links.

Module Contents

Classes

PubSubTopicLink

Helper class for constructing Pub/Sub Topic Link

PubSubSubscriptionLink

Helper class for constructing Pub/Sub Subscription Link

Attributes

PUBSUB_BASE_LINK

PUBSUB_TOPIC_LINK

PUBSUB_SUBSCRIPTION_LINK

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]

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]

Was this entry helpful?