airflow.providers.google.cloud.links.managed_kafka¶

属性¶

`MANAGED_KAFKA_BASE_LINK`
`MANAGED_KAFKA_CLUSTER_LINK`
`MANAGED_KAFKA_CLUSTER_LIST_LINK`
`MANAGED_KAFKA_TOPIC_LINK`
`MANAGED_KAFKA_CONSUMER_GROUP_LINK`

`ApacheKafkaClusterLink`	用于构建 Apache Kafka Cluster 链接的辅助类。
`ApacheKafkaClusterListLink`	用于构建 Apache Kafka Clusters 链接的辅助类。
`ApacheKafkaTopicLink`	用于构建 Apache Kafka Topic 链接的辅助类。
`ApacheKafkaConsumerGroupLink`	用于构建 Apache Kafka Consumer Group 链接的辅助类。

airflow.providers.google.cloud.links.managed_kafka.MANAGED_KAFKA_BASE_LINK = '/managedkafka'[source]¶

airflow.providers.google.cloud.links.managed_kafka.MANAGED_KAFKA_CLUSTER_LINK = '/managedkafka/{location}/clusters/{cluster_id}?project={project_id}'[source]¶

airflow.providers.google.cloud.links.managed_kafka.MANAGED_KAFKA_CLUSTER_LIST_LINK = '/managedkafka/clusters?project={project_id}'[source]¶

airflow.providers.google.cloud.links.managed_kafka.MANAGED_KAFKA_TOPIC_LINK = '/managedkafka/{location}/clusters/{cluster_id}/topics/{topic_id}?project={project_id}'[source]¶

airflow.providers.google.cloud.links.managed_kafka.MANAGED_KAFKA_CONSUMER_GROUP_LINK = '/managedkafka/{location}/clusters/{cluster_id}/consumer_groups/{consumer_group_id}?project={project_id}'[source]¶

class airflow.providers.google.cloud.links.managed_kafka.ApacheKafkaClusterLink[source]¶

用于构建 Apache Kafka Cluster 链接的辅助类。

format_str = '/managedkafka/{location}/clusters/{cluster_id}?project={project_id}'[source]¶

static persist(context, task_instance, cluster_id)[source]¶

class airflow.providers.google.cloud.links.managed_kafka.ApacheKafkaClusterListLink[source]¶

用于构建 Apache Kafka Clusters 链接的辅助类。

static persist(context, task_instance)[source]¶

class airflow.providers.google.cloud.links.managed_kafka.ApacheKafkaTopicLink[source]¶

用于构建 Apache Kafka Topic 链接的辅助类。

format_str = '/managedkafka/{location}/clusters/{cluster_id}/topics/{topic_id}?project={project_id}'[source]¶

static persist(context, task_instance, cluster_id, topic_id)[source]¶

class airflow.providers.google.cloud.links.managed_kafka.ApacheKafkaConsumerGroupLink[source]¶

用于构建 Apache Kafka Consumer Group 链接的辅助类。

format_str = '/managedkafka/{location}/clusters/{cluster_id}/consumer_groups/{consumer_group_id}?project={project_id}'[source]¶

static persist(context, task_instance, cluster_id, consumer_group_id)[source]¶