airflow.providers.google.cloud.links.pubsub¶

This module contains Google Pub/Sub links.

Attributes¶

`PubSubTopicLink`	Helper class for constructing Pub/Sub Topic Link.
`PubSubSubscriptionLink`	Helper class for constructing Pub/Sub Subscription Link.

airflow.providers.google.cloud.links.pubsub.PUBSUB_BASE_LINK = '/cloudpubsub'[source]¶

airflow.providers.google.cloud.links.pubsub.PUBSUB_TOPIC_LINK = '/cloudpubsub/topic/detail/{topic_id}?project={project_id}'[source]¶

airflow.providers.google.cloud.links.pubsub.PUBSUB_SUBSCRIPTION_LINK = '/cloudpubsub/subscription/detail/{subscription_id}?project={project_id}'[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]¶: Name of the link. This will be the button name on the task UI.

format_str = '/cloudpubsub/topic/detail/{topic_id}?project={project_id}'[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]¶: Name of the link. This will be the button name on the task UI.

format_str = '/cloudpubsub/subscription/detail/{subscription_id}?project={project_id}'[source]¶

static persist(context, task_instance, subscription_id, project_id)[source]¶