文档中心

消息队列 RocketMQ版

请输入

Python SDK

参数说明

本文介绍您在使用 Python SDK 接入火山引擎消息队列 RocketMQ版时，需要配置的参数。

消息发送参数

配置示例：

producer = Producer(producer_group)​
producer.set_name_server_address("your-nameserver-addr")​

参数说明：

参数	是否必选	说明	配置方式
set_group	必选	生产者 Group 名称。	producer.set_group("demo-group")
set_name_server_address	必选	指定 NameServer 接入点。	producer.set_name_server_address("http://rocketmq-xxxxxxxx.rocketmq.ivolces.com:9876")
set_session_credentials	必选	RocketMQ 密钥信息，包括 AccessKey 和 SecretKey。	producer.set_session_credentials("ak", "sk", "")
set_timeout	可选	设置消息发送的超时时间，单位为毫秒。	producer.set_timeout(30000)
set_max_message_size	可选	设置最大消息大小，单位为字节。	producer.set_max_message_size(4096)
set_compress_level	可选	设置压缩等级。	producer.set_compress_level(3)

消息消费参数

参数	是否必选	说明	配置方式
set_name_server_address	必选	指定 NameServer 接入点。	consumer.set_name_server_address("http://rocketmq-xxxxxxxx.rocketmq.ivolces.com:9876")
set_session_credentials	必选	RocketMQ 密钥信息，包括 AccessKey ID 和 AccessKey Secret。	consumer.set_session_credentials("ak", "sk", "")
set_message_model	可选	设置消费模式，广播或集群模式。	consumer.set_message_model()
set_thread_count	可选	设置线程数。	consumer.set_thread_count(1)
set_message_batch_max_size	可选	设置每批消费最大的消息条数。	consumer.set_message_batch_max_size(1)
set_instance_name	可选	设置消费者实例名称。	consumer.set_instance_name("abc")

最近更新时间：2025.07.09 16:22:42

这个页面对您有帮助吗？

有用

无用