在运行 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
。详细说明请参考注意事项。
- 创建 RocketMQ 实例,并记录接入点地址。
详细操作步骤请参考创建实例。
创建实例后,您可以在实例的概览页面服务访问区域中查看接入点的信息。 - 创建 Group,并获取 GroupID。
详细操作步骤请参考创建 Group。
创建 Group 后,可以在实例的Group管理页签中查看 GroupID。 - 创建 Topic,并获取 Topic 名称。
详细操作步骤请参考创建Topic。
创建 Topic 后,可以在实例的Topic管理页签中查看 Topic 名称。 - 创建密钥,并记录 AK 和 SK。
详细操作步骤请参考创建密钥。
创建密钥后,可以在密钥管理页签中查看已创建的 AccessKey ID 及 AccessKey Secret。
后续步骤