使用pykestrel:Kestrel队列系统的Python库
我刚接触异步消息队列,打算在我的项目中使用Python的kestrel库,也就是pykestrel(https://github.com/empower/pykestrel)。
在GitHub页面上的示例中,有这样一行代码:
q.add("test job")
那么“test job”实际上是什么意思呢?有没有人能提供一些更多的例子,来演示如何使用pykestrel?
请帮帮我
谢谢
3 个回答
0
"测试任务"实际上是你工作者需要执行的操作的描述。举个例子,如果你是一个视频网站,当你收到一个新视频时:
"MakeIcon('/path/to/video')"
你的工作者程序应该根据这个消息知道该怎么做。这个消息可以更复杂,包含更多的信息。
它可以是任何内容,编码方式也可以随你选择。
0
为了后人记住,原始项目可以在这里找到:https://github.com/matterkkila/pykestrel/,这个项目是更新版的。
0
你提到的代码是用来往 Kestrel 队列里添加一条消息的。
kestrel.next()
这段代码会获取队列里的下一条消息。
你可以在这个链接找到完整的文档:https://github.com/empower/pykestrel/blob/master/kestrel/client.py
另外,Kestrel 使用的是 memcache 协议,你可以在这里找到相关信息:http://code.sixapart.com/svn/memcached/trunk/server/doc/protocol.txt
简单来说,任何可以和 Memcache 一起工作的东西,都可以用在 Kestrel 上。