文档首页 > > 开发指南> SDK> Python> DMS Python SDK示例

DMS Python SDK示例

分享
更新时间: 2019/11/15 GMT+08:00

分布式消息服务(Distributed Message Service)是一项基于高可用分布式集群技术的消息中间件服务,具有大规模、高可靠、高并发访问、可扩展且完全托管的特点。DMS帮助云端的应用程序组件去耦合,具有很高的成本效益。

创建队列

下面代码为消息队列创建的过程,创建成功后,可在此队列上生产消息,示例:

1
2
3
4
5
queue_dict = {
                'name': "dmsTestQueue" + self.timeStamp,
                'description': "dmsTestQueue" + self.timeStamp
}
q = conn.dms.create_queue(**queue_dict)

创建消费组

下面代码为消费组创建的过程,创建完成后,新创建的消费组,可消费队列上的消息,示例:

1
2
3
4
5
6
7
8
groupDict = {
            "groups": [
                {
                    "name": "dmsConsumeGroup" + self.timeStamp
                }
            ]
 }
group = conn.dms.create_groups(queue, **groupDict)

生产消息

下面代码为生产消息的过程,示例:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
msgDict = {
            "messages": [
                {
                    "body": "testMsg" + self.timeStamp,
                    "attributes":
                    {
                        "attribute1": "value1",
                        "attribute2": "value2"
                    }
                }
            ]
 }
conn.dms.send_messages(queue, **msgDict))

消费消息

下面代码为消费消息的过程,示例:

1
msgList =  conn.dms.consume_message(queue, group[0].id)
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区