pysubman 1.20.1.4

版本更新

• 1.20.1.4
• 1.20.1.3修改redis rpop到brpop
• 1.20.1.1添加redis消息默认前缀mq:
• 1.20.1.0重新发行
• 1.10.4添加生产者投入返回值
• 1.10.4添加豆茎；修改客户生产者口
• 1.10.2去掉记录
• 1.10.0将kafka迁31227;到豆茎

开始

生产者

#!/usr/bin/env python# coding=utf-8importjsonimporttimefrompysubman.redis.clientimportClientclient=Client(host="127.0.0.1:6379:5")message=json.dumps({"type":"linkedin","time":time.time(),})client.publish("oauth:linkedin",message)

客户

#!/usr/bin/env python# coding=utf-8frompysubman.redis.clientimportClientfrompysubman.redis.serviceimportServicefrompysubman.redis.subscribeimportSubscriberservices=Service()@services.C("oauth:linkedin")defhandler_email_job(body):logging.warn(("body",body))defmain():Subscriber(Client(host="127.0.0.1:6379:5")).subscribe(services)if__name__=="__main__":main()

待办事项

• TCP协议

支架

如果您需要使用pysubman的帮助或发现错误，请打开github issue。