取消客户资格
pydisque的Python项目详细描述
Pydire
disme的客户端，内存中的分布式作业队列。
文档
用法
通过传递节点列表来创建新的DISQUE客户机：
frompydisque.clientimportClientclient=Client(["127.0.0.1:7711","127.0.0.1:7712","127.0.0.1:7713"])client.connect()
如果它无法连接到第一个节点，它将尝试连接到第二个节点，等等。如果它无法连接到任何节点，它将引发一个redis.exceptions.connectionerror，如您所想象的。
现在您可以添加作业：
client.add_job("test_queue",json.dumps(["print","hello","world",time.time()]),timeout=100)
它将作业“print”推送到队列“test_queue”，超时100 ms，如果接收并复制了作业，则返回作业的id 及时。如果无法到达节点（可能是关闭等），它将重试连接到给定节点列表中的另一个节点，然后发送作业。如果节点列表中没有可用的节点，则显然会引发连接错误
然后，您的员工将执行以下操作：
whileTrue:jobs=client.get_job(['test_queue'])forqueue_name,job_id,jobinjobs:job=json.loads(job)print">>> received job:",jobclient.ack_job(job_id)
还要检查示例目录。
在等待作业时，连接的节点可能会关闭，Pydunce将尝试连接到下一个节点，这样您就可以重新启动节点而不必关闭客户端。
文档
现在请检查disque/client.py中的docstrings，实现的命令是
- 信息
- 添加作业
- 找工作
- 确认工作
- Nack_作业
- 快速确认
- 工作
- Qlen
- qstat
- Qpeek
- qscan
- jscan
- 排队
- 出列
- 删除作业
- 显示
- 暂停
- 你好
安装
您可以使用pip安装它。
$ pip install pydisque
许可证
这个项目是根据麻省理工学院的许可条款授权的
学分
欢迎加入QQ群-->： 979659372
