python - 使用 pykestrel，用于 kestrel 队列系统的 python 库

Question

我是异步消息队列的新手，将在我的项目（https://github.com/empower/pykestrel）中使用 python api 到 kestrel、pykestrel。
github页面上的示例有以下行：

q.add("测试作业")

什么是实践中的测试工作？有人可以提供更多示例来演示 pykestrel 的使用吗？

请帮忙
谢谢

Answer 1

您问题中的代码向 Kestrel 队列添加了一条消息。

kestrel.next()

将获得队列中的下一条消息。

您可以在代码中找到完整的文档：https ://github.com/empower/pykestrel/blob/master/kestrel/client.py

此外，红隼使用你可以在这里找到的内存缓存协议：http: //code.sixapart.com/svn/memcached/trunk/server/doc/protocol.txt

基本上，任何与 Memcache 一起使用的东西都可以与 Kestrel 一起使用。

Answer 2

实际上，“测试工作”是对您的工人要完成的操作的描述。例如，如果您是视频网站，一旦您收到新视频：

"MakeIcon('/path/to/video')"

您的工作进程应该知道根据该消息做什么。消息可以更大并且包含更多信息。

它可以是任何东西，随意编码。

Answer 3

对于后代，请注意原始项目位于https://github.com/matterkkila/pykestrel/并且更新。