HotQueue—在Python程序中用Redis做FIFO消息队列

HotQueue

HotQueue是一个Python库,允许您在Python程序中将Redis用作FIFO消息队列。

安装

pip install -U hotqueue

使用

1、建立一个py当做worker

simple_worker.py

from hot_queue import HotQueue
class MQCon(object):
    """queue 连接单例类"""
    _mq = None

    @classmethod
    def get_connection(cls):
        if cls._mq is None:
            cls._mq = HotQueue("redis_key", host='redishost', port='redisport')
        return cls._mq

if __name__ == '__main__':
    queue = MQCon.get_connection()


    @queue.worker
    def square(num):
        print num * num
        print(square())
2、在其他地方使用
from simple_worker import MQCon

queue = MQCon.get_connection()
queue.put(5, 3, 4)
3、注释

这里只是 quick start ,详情请参阅官方文档:

http://richardhenry.github.io/hotqueue/

hotqueue监控工具:

https://github.com/richardhenry/hotwatch
队列 
更新时间:2016-04-01 13:49:43

本文由 智慧煮粥 创作,如果您觉得本文不错,请随意赞赏
采用 知识共享署名4.0 国际许可协议进行许可
本站文章除注明转载/出处外,均为本站原创或翻译,转载前请务必署名
原文链接:http://zz.zzhub.cn/archives/hotqueuepython
最后更新:2016-04-01 13:49:43

评论

Your browser is out of date!

Update your browser to view this website correctly. Update my browser now

×