Skip to content

Latest commit

 

History

History
129 lines (77 loc) · 2.83 KB

README.md

File metadata and controls

129 lines (77 loc) · 2.83 KB
Raw

ShopEx Prism sdk (python version)

用途

实现ShopEx Prism 的Python版SDK供第三方使用

功能

提供http API调用（GET/POST方式）
连接WebSocket，可以发布/消费/应答消息
提供oauth认证

要求

python sdk 2.6或者以上更高的版本

打包、安装、日志

1、打包

git clone https://github.com/shopex/prism-python

cd prism-python/

python setup.py sdist  #构建Prism SDK完成，构建SDK位于.dist目录中

ps:版本号只需 com.version.py 中version=XXX修改即可

2、安装

tar -zxvf prism-python-0.1.tar.gz

cd prism-python-0.1

python setup.py install  #安装Prism SDK完成

3、日志

日志级别的修改com.shopex.config.py 讲LOG_LEVEL改成对应的ERROR、WARNING、INFO、DEBUG

使用方法

###1、提供HTTP API调用(GET/POST)(参考如下TestCase代码)

ps:

import unittest

from com.shopex.prism.PrismClient import PrismClient


class PrismClientTestCase(unittest.TestCase):
    def setUp(self):
        self.url = "http://dilbmtcv.apihub.cn/api";
        self.key = "buwb2lii"
        self.secret = "ucr72ygfutspqeuu6s36"
        self.prismClient = PrismClient(self.url, self.key, self.secret)

    def testDoGet(self):
        params = {}
        print self.prismClient.do_get("/platform/notify/status", params)

    def testDoPost(self):
        params = {"data": "hello"}
        print self.prismClient.do_post("/platform/notify/write", params)


if __name__ == '__main__':
    unittest.main()

返回是一串json格式的response消息体

###2、OAuth认证

url = "http://dilbmtcv.apihub.cn/api"
key = "buwb2lii"
secret = "ucr72ygfutspqeuu6s36"

prism_oauth = PrismOauth(self.url, self.key, self.secret, session)
prism_oauth.require_oauth()   //启动OAuth认证

###3、WebSocket

a、建立websocket连接

设置websocket生命周期函数 参考PrismClientTestCase的class PrismMessageHandler()

method = "/platform/notify";
prism_notify = prismClient.notify(method, PrismMessageHandler(sleep=60, retry_times=3))

增加了websocket 断开重试机制 self.retry_times = retry_times #重试次数,默认断开后一直重试 self.sleep = sleep #间歇时间,默认断开每隔1分钟重试

b、发布消息

prism_notify.publish("order.new","hello world");

c、开启队列消费

queue_name = "" --- 待消费的队列名 (空值或者不传 - prism 默认队列,非空指定消费队列)
prism_notify.consume(queue_name);