文档中心

参数说明

最近更新时间：2023.05.12 15:10:40

首次发布时间：2023.05.12 15:10:40

本文介绍您在使用 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")`

消息发送参数

消息消费参数