Complete the airflow survey & get a free airflow 3 certification!

tests.system.google.cloud.managed_kafka.example_managed_kafka_topic¶

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

Attributes¶

`ENV_ID`
`PROJECT_ID`
`DAG_ID`
`LOCATION`
`CLUSTER_ID`
`CLUSTER_CONF`
`TOPIC_ID`
`TOPIC_CONF`
`TOPIC_TO_UPDATE`
`TOPIC_UPDATE_MASK`
`create_cluster`
`test_run`

Module Contents¶

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

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

tests.system.google.cloud.managed_kafka.example_managed_kafka_topic.DAG_ID = 'managed_kafka_topic_operations'[source]¶

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

tests.system.google.cloud.managed_kafka.example_managed_kafka_topic.CLUSTER_ID = ''[source]¶

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

tests.system.google.cloud.managed_kafka.example_managed_kafka_topic.TOPIC_ID = ''[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_topic.TOPIC_CONF[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_topic.TOPIC_TO_UPDATE[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_topic.TOPIC_UPDATE_MASK: dict[source]¶

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

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

Was this entry helpful?