tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group¶

用于测试Google Cloud Managed Service for Apache Kafka主题操作的Airflow DAG示例。

属性¶

`ENV_ID`
`PROJECT_ID`
`DAG_ID`
`LOCATION`
`CLUSTER_ID`
`CLUSTER_CONF`
`TOPIC_ID`
`TOPIC_CONF`
`CONSUMER_GROUP_ID`
`CONNECTION_ID`
`PORT`
`BOOTSTRAP_URL`
`log`
`create_cluster`
`test_run`

函数¶

`producer`()	生产并提交10条消息
`consumer`(message)	接收已消费的消息并将其内容打印到日志中。

模块内容¶

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

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

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.DAG_ID = 'managed_kafka_consumer_group_operations'[source]¶

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

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

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

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

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

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.CONSUMER_GROUP_ID = ''[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.CONNECTION_ID = 'connection_managed_kafka_consumer_group_operations_Uninferable'[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.PORT = '9092'[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.BOOTSTRAP_URL[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.log[source]¶

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.producer()[source]¶: 生产并提交10条消息

tests.system.google.cloud.managed_kafka.example_managed_kafka_consumer_group.consumer(message)[source]¶: 接收已消费的消息并将其内容打印到日志中。

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

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

此条目有帮助吗？