Python Disque客户端(非常非常初步,Disque本身也是这样)
项目描述
# Disque-py
A [disque](https://github.com/antirez/disque) Python客户端。
底层使用redis-py的HiRedis实现,并用disque命令替换了Redis命令。
## 使用
from disque import DisqueAlpha
```
c = DisqueAlpha()
c.addjob('queuename', 'body') # takes all ADDJOB arguments
# b'DI... job id ...SQ'
c.getjob('queuename')
# [[b'queue', b'DI3971f14a850d9e5b3ca5c881e3dd1ba2a34277b505a0SQ', b'body']]
## 状态
```
- [x] 服务器命令(slowlog,clients等)
- [x] ADDJOB
- [x] GETJOB
- [ ] ACKJOB
- [ ] FASTACK
- [ ] Status
A [disque](https://github.com/antirez/disque) Python客户端。
底层使用redis-py的HiRedis实现,并用disque命令替换了Redis命令。
## 使用
from disque import DisqueAlpha
```
c = DisqueAlpha()
c.addjob('queuename', 'body') # takes all ADDJOB arguments
# b'DI... job id ...SQ'
c.getjob('queuename')
# [[b'queue', b'DI3971f14a850d9e5b3ca5c881e3dd1ba2a34277b505a0SQ', b'body']]
## 状态
```
- [x] 服务器命令(slowlog,clients等)
- [x] ADDJOB
- [x] GETJOB
- [ ] ACKJOB
- [ ] FASTACK
- [ ] Status