百度消息服务Python样例
百度消息服务是分布式、高可扩展、高通量的托管消息队列服务。完全兼容开源Kafka。本样例展示如何使用官方推荐的confluent-kafka-python客户端访问百度消息服务。
环境要求
准备工作
细节请参考BCE官网帮助文档
- 在管理控制台中创建好主题，并获取主题名称topic_name。
- 在管理控制台中下载您的kafka-key.zip，包含Go程序使用的
client.pem，client.key，ca.pem。 - 用上一步的文件替换样例代码中的
client.pem、client.key以及ca.pem。
运行样例代码
python consumer.py --topic topic_name
python producer.py --topic topic_name