python使用rabbitmq阻塞_python – Celery/RabbitMQ unacked消息阻塞队列?
我已经调用了一个任务,用urllib2远程获取一些信息几千次.这些任务是使用随机eta(一周内)安排的,因此它们都不会同时命中服务器.有时我会得到404,有时候不会.我正在处理错误,以防它发生.
在RabbitMQ控制台中,我可以看到16条未确认的消息:
我停下芹菜,清理队列并重新启动它. 16条未经确认的消息仍在那里.
我有其他任务进入同一队列,也没有执行任何任务.清除之后,我尝试提交另一项任务,状态仍然准备就绪:
我有什么想法可以找出为什么消息仍未被承认?
版本:
celery==3.1.4
{rabbit,"RabbitMQ","3.5.3"}
celeryapp.py
CELERYBEAT_SCHEDULE = {
'social_grabber': {
'task': '.tasks.task_social_grabber',
'schedule': crontab(hour=5, minute=0, day_of_week='sunday'),
},
}
tasks.py
@app.task
def task_social_grabber():
for user in users:
eta = randint(0, 60 * 60 * 24 * 7) #week in seconds
task_social_grabber_single.apply_async((user), countdown=eta)
没有定义此任务的路由,因此它进入默认队列:celery.有一个工作人员处理此队列.
supervisord.conf:
[program:celery]
autostart = true
autorestart = true
command = celery worker -A .celeryapp:app --concurrency=3 -l INFO -n celery
python使用rabbitmq阻塞_python – Celery/RabbitMQ unacked消息阻塞队列?相关推荐
- python复制文件夹不阻塞_Python线程,线程不阻塞
我有一个Python程序,当我使用Ctrl-c退出应用程序时,脚本不会关闭.我的进程仍然显示在运行进程中.#!/usr/bin/env python import socket import thre ...
- pythontcp服务器如何关闭阻塞_python实现单线程多任务非阻塞TCP服务端
本文实例为大家分享了python实现单线程多任务非阻塞TCP服务端的具体代码,供大家参考,具体内容如下 # coding:utf-8 from socket import * # 1.创建服务器soc ...
- python3socket非阻塞_Python的socket.accept非阻塞吗?
你可能想要类似的东西select.select().你提供select()了三个套接字列表:要监视的可读性,可写性和错误状态的套接字.当新客户端在等待时,服务器套接字将可读. 该select()功能将 ...
- python queue get 方法_Python语言中的Queue(队列)
本文主要向大家介绍了Python语言中的Queue,通过具体的内容向大家展示,希望对大家学习Python语言有所帮助. 什么是队列? 队列就像是水管子,先进先出,与之相对应的是栈,后进先出. 队列是线 ...
- python定时发送信息_python实现定时发送消息
#!/usr/bin/env python #-*- coding:utf-8 -*- @Author : wujf @Time:2018/8/21 15:59 # 自动发送消息 from threa ...
- python中怎么撤回_python如何查看微信消息撤回
本文为大家分享了python查看微信消息撤回的具体代码,供大家参考,具体内容如下 1.安装itchat itchat是一个开源的python微信库,支持发送消息.图片.视频.地图.名片.文件等,还可以 ...
- python 操作微信 群发_python 调用微信 发消息
本篇文章讲述的是调用 python 的 wxpy 包自动发送微信消息. 相当于 登录 微信网页版. 具体代码方便复制,提供一份文字版代码 #!/usr/bin/env python3 # coding ...
- Celery+Rabbitmq实现异步任务
Celery+Rabbitmq实现异步任务 一. 安装celery,再安装rabbitmq或redis pip install celery rabbitmq和redis安装其中一个就可以了,cele ...
- Django + Nginx + Uwsgi + Celery + Rabbitmq 做一个高速响的应网站架构
Django :渲染页面,站点访问控制,管理网站,网站框架 Nginx:ip访问管理,数据传输控制 Uwsgi:处理链接Diango和Nginx的传输协议,也可以看作是处理客户端数据和Django之间 ...
最新文章
- linux 性能 管理 与 优化
- 画布之轮播图片HTML5,Axure原型设计之轮播图
- 波形的转换与信号处理
- java动态代理(JDK和cglib)
- REDIS 在电商中的实际应用场景(转)
- c#UDP发送接收消息
- DMM通过增加USDK作为支持的mToken提案
- dom4j的操作(增删改查)
- 【数据预测】基于matlab BP+ELM+LSTM+BiLSTM+SAELSTM数据预测【含Matlab源码 1825期】
- 【游戏】基于matlab GUI万年历【含Matlab源码 257期】
- 实时帧数手机_实时音频的混音在视频直播中的技术原理和实践总结
- 谷歌浏览器的视频下载插件推荐
- 计算机课代表总结,计算机班的班主任工作总结.doc
- DeepFool论文阅读
- 均值归一化_深度神经网络中的归一化技术
- 禁用eslint / ts相关检查
- EVB_MX+ TencentOS tiny物联网开发板首次使用记录路灯调试(1)
- ANDROID中的VOLD分析
- OpenGL---PBO
- 远景在线(www.pcbeta.com):使用IE10登陆中国银行网银蓝屏或者死机的解决方案