tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster¶

Example Airflow DAG for Google Cloud Managed Service for Apache Kafka testing Cluster operations.

Attributes¶

`ENV_ID`
`PROJECT_ID`
`DAG_ID`
`LOCATION`
`CLUSTER_ID`
`CLUSTER_CONF`
`CLUSTER_TO_UPDATE`
`CLUSTER_UPDATE_MASK`
`create_cluster`
`test_run`

Module Contents¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster.ENV_ID[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster.PROJECT_ID[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster.DAG_ID = 'managed_kafka_cluster_operations'[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster.LOCATION = 'us-central1'[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster.CLUSTER_ID[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster.CLUSTER_CONF[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster.CLUSTER_TO_UPDATE[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster.CLUSTER_UPDATE_MASK[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster.create_cluster[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_cluster.test_run[source]¶

Was this entry helpful?