跳转到主要内容

使用redis作为后端实现的一个持久化、(主要)原子队列(类似于deque或Queue)。

项目描述

redis_queue对于实现多生产者、

多消费者工作队列很有用。虽然它没有Queue的所有方便的阻塞和锁定功能,但它具有多进程安全性和持久性的优势。

示例用法:
>>> from redis import Redis
>>> from redis_queue import Queue
>>> redis = Redis(host='127.0.0.1', port=6379)
>>> queue = Queue(redis, 'test_queue')
>>> queue.append('one')
>>> queue.append('two')
>>> queue.append('three')
>>> queue.pop()
'three'
>>> queue.pop()
'two'
>>> queue.pop()
'one'
>>> queue.append('one')
>>> queue.append('two')
>>> queue.append('three')
>>> queue.popleft()
'one'
>>> queue.popleft()
'two'
>>> queue.popleft()
'three'

项目详情


下载文件

下载适合您平台的应用程序文件。如果您不确定选择哪个,请了解更多关于安装包的信息。

源分布

redis_queue-0.5.tar.gz (7.5 kB 查看散列)

上传时间:

由以下支持

AWS AWS 云计算和安全赞助商 Datadog Datadog 监控 Fastly Fastly CDN Google Google 下载分析 Microsoft Microsoft PSF 赞助商 Pingdom Pingdom 监控 Sentry Sentry 错误日志 StatusPage StatusPage 状态页面