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

DMS Python SDK示例

更新时间: 2018-11-26 14:28

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

创建队列

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

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

创建消费组

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

groupDict = {
            "groups": [
                {
                    "name": "dmsConsumeGroup" + self.timeStamp
                }
            ]
 }
group = conn.dms.create_groups(queue, **groupDict)

生产消息

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

msgDict = {
            "messages": [
                {
                    "body": "testMsg" + self.timeStamp,
                    "attributes":
                    {
                        "attribute1": "value1",
                        "attribute2": "value2"
                    }
                }
            ]
 }
conn.dms.send_messages(queue, **msgDict))

消费消息

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

msgList =  conn.dms.consume_message(queue, group[0].id)

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

提交成功!

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

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

在文档使用中是否遇到以下问题







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

字符长度不能超过100

反馈内容不能为空!

提交反馈 取消

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

跳转到云社区
点我,12·12惊喜等着你哦~