一个简单但有用的redis队列/工作进程
py_redis_simple_queue的Python项目详细描述
redis简单队列
文章中非常简单的实现：http://peter-hoffmann.com/2012/python-simple-queue-redis-queue.html
用法
pip install py_redis_simple_queue
发送者
fromredisimportRedisfromredis_simple_queueimportRedisQueueconnection=Redis()# see docs at https://docs.objectrocket.com/redis_python_examples.htmlqueue=RedisQueue('my_queue',connection)queue.put('my message')
工人
fromredisimportRedisfromredis_simple_queueimportWorker,RedisQueueclassMyWorker(Worker):defrun(self,msg):print(msg)# do something with messageconnection=Redis()queue=RedisQueue('my_queue',connection)worker=MyWorker(queue)worker.dequeue()
欢迎加入QQ群-->： 979659372
