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

Attributes¶

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

`ApacheKafkaClusterLink`	Helper class for constructing Apache Kafka Cluster link.
`ApacheKafkaClusterListLink`	Helper class for constructing Apache Kafka Clusters link.
`ApacheKafkaTopicLink`	Helper class for constructing Apache Kafka Topic link.

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

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

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

Helper class for constructing Apache Kafka Cluster link.

name = 'Apache Kafka Cluster'[source]¶: Name of the link. This will be the button name on the task UI.

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

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

Helper class for constructing Apache Kafka Clusters link.

name = 'Apache Kafka Cluster List'[source]¶: Name of the link. This will be the button name on the task UI.

static persist(context, task_instance)[source]¶

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

Bases: airflow.providers.google.cloud.links.base.BaseGoogleLink

Helper class for constructing Apache Kafka Topic link.

name = 'Apache Kafka Topic'[source]¶: Name of the link. This will be the button name on the task UI.

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

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