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]¶