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

此模块包含 Google Pub/Sub 链接。

模块内容¶

`PubSubTopicLink`	用于构建 Pub/Sub 主题链接的辅助类。
`PubSubSubscriptionLink`	用于构建 Pub/Sub 订阅链接的辅助类。

airflow.providers.google.cloud.links.pubsub.PUBSUB_BASE_LINK = '/cloudpubsub'[源代码]¶

class airflow.providers.google.cloud.links.pubsub.PubSubTopicLink[源代码]¶

基类: airflow.providers.google.cloud.links.base.BaseGoogleLink

用于构建 Pub/Sub 主题链接的辅助类。

static persist(context, task_instance, topic_id, project_id)[源代码]¶

class airflow.providers.google.cloud.links.pubsub.PubSubSubscriptionLink[源代码]¶

基类: airflow.providers.google.cloud.links.base.BaseGoogleLink

用于构建 Pub/Sub 订阅链接的辅助类。

static persist(context, task_instance, subscription_id, project_id)[源代码]¶