文档中心

消息队列 RocketMQ版

Python SDK

准备工作

在运行 Python SDK 代码收发消息前，您需按照本文提供的步骤来准备开发环境。

前提条件

已安装 Python 开发环境。

请参考 Python 官网下载并安装 Python 开发环境或使用 conda 创建 Python 虚拟环境。

已确认 Python 版本。

Python SDK 支持 Python 3.5 及后续版本，您可执行以下命令检查当前 Python 的版本信息。

python -V

安装 pip。

安装方式请参考 pip 官方文档。

操作步骤

1 安装依赖

创建 Python 项目。

安装 librocketmq。

rocketmq-client-python 的功能通过封装 rocketmq-client-cpp 实现，因此需要先安装依赖 librocketmq。根据您使用的操作系统下载对应的安装包，相关说明请参考 rocketmq-client-cpp-2.0.0。

安装 rocketmq-client-python。

rocketmq-client-python 是 RocketMQ 的社区版 SDK，可通过如下命令直接安装：

pip install rocketmq-client-python

2 创建资源

接入消息队列 RocketMQ版收发消息前，需要先在控制台中创建相关资源，调用相关接口类收发消息时需要在代码中配置资源 ID 或 AK/SK。

说明

对于 2022年12月16日及之前创建的 RocketMQ 实例，通过 Go、Python、C++ 等除 Java 以外其他语言的 SDK 收发消息时，需要通过拼接实例 ID 的格式指定 Topic 或 Group，即 InstanceID%GroupID，例如MQ_INST_85bclzugcfkd_nxxxx%demo-group。详细说明请参考注意事项。