You need to enable JavaScript to run this app.
导航
参数说明
最近更新时间: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")