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

针对 Google Cloud Managed Service for Apache Kafka 测试集群操作的示例 Airflow DAG。

属性¶

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

模块内容¶

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

此条目有帮助吗？