消息队列 RocketMQ版
消息队列 RocketMQ版
消息队列 RocketMQ版
文档指南
请输入
产品动态
用户指南
实例管理
后台任务管理
Terraform
RocketMQ Agent
API 参考
实例管理
Topic管理
Group管理
消息查询
死信队列
密钥管理
风险巡检
白名单管理
终端节点服务
SDK 参考
RocketMQ 5.x
RocketMQ 4.x
RocketMQ 管控面SDK
最佳实践
- 文档首页
消息队列 RocketMQ版SDK 参考RocketMQ 4.xPython SDK参数说明
复制全文
下载 pdf参数说明
文档反馈
问问助手本文介绍您在使用 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
这个页面对您有帮助吗？
有用
有用
无用
无用