Redis QueuePython 作业队列系统
RQ (Redis Queue) 是一个简单的 Python 库,用于实现作业的队列,并在后台进行处理。后端基于 Redis ,可方便集成到 Web 应用中,要求 Redis >= 2.6.0
示例代码:
from rq import Queue from redis import Redis from somewhere import count_words_at_url # Tell RQ what Redis connection to use redis_conn = Redis() q = Queue(connection=redis_conn) # no args implies the default queue # Delay execution of count_words_at_url('http://nvie.com') job = q.enqueue(count_words_at_url, 'http://nvie.com') print job.result # => None # Now, wait a while, until the worker is finished time.sleep(2) print job.result # => 889
后台作业处理 worker:
$ rqworker *** Listening for work on default Got count_words_at_url('http://nvie.com') from default Job result = 818 *** Listening for work on default
评论
MartinetNode.js 分布式作业队列
Martinet是分布式任务管理工具。Martinet数据库后端,基于zeroMQ的分布式任务管理系统。Martinet可以使用任意的sequelize.js兼容的数据库(默认是SQLite)。Mar
MartinetNode.js 分布式作业队列
0
taskqGolang 异步任务/作业队列
taskq 是一个带有Redis、SQS、IronMQ和内存后端的Golang异步任务/作业队列。特性:Redis、SQS、IronMQ和内存后端。自动缩放用于获取(fetcher)和处理消息(wor
taskqGolang 异步任务/作业队列
0