58得票7回答
Celery与Amazon SQS

我想使用Amazon SQS作为Celery的消息代理。对于此,Kombu提供了SQS传输实现来支持Celery。然而,并没有足够的文档说明如何在Celery中配置SQS,因此我无法找到正确的配置方法。是否有人成功地在Celery中配置过SQS?

57得票8回答
生产环境中的Celery Flower安全性

我希望使用 Flower (https://github.com/mher/flower) 监测我的 Celery 任务,代替 Django-Admin 如文档所推荐 (http://docs.celeryproject.org/en/latest/userguide/monitoring.h...

56得票2回答
在Celery中通过id检索任务结果

我正在尝试检索已完成任务的结果。这是有效的from proj.tasks import add res = add.delay(3,4) res.get() 7 res.status 'SUCCESS' res.id '0d4b36e3-a503-45e4-9125-cfec0a7dca30'...

55得票5回答
如何停止Celery工作进程

我在Ubuntu EC2节点上拥有一个Django项目,我一直在使用Celery来设置异步任务。 我正在遵循此教程以及官方文档。 我已经能够在命令行上使用以下命令来运行一个基本的任务:(env1)ubuntu@ip-172-31-22-65:~/projects/tp$ celery --ap...

54得票3回答
Celery无法使用redis

尝试首次启动Celery时出现以下错误,我已经安装了Redis并且它运行正常,但某种方式Django似乎与其存在问题。 第一次启动Celery时出现错误,已安装Redis并且它正常运行,但Django似乎仍然无法使用它。File "<frozen importlib._boo...

54得票4回答
属性错误:'Flask'对象没有'user_options'属性。

我正在尝试设置以下文档中的基本示例: http://flask.pocoo.org/docs/patterns/celery/ 但是到目前为止,我一直收到以下错误: AttributeError: 'Flask'对象没有属性'user_options' 我正在使用cel...

54得票3回答
Python任务队列的替代方案和框架

Python 3似乎有不同的实现任务/作业队列: Celery,流行但似乎没有维护和过时; RQ,我了解很少有关它的信息; TaskTiger,类似于RQ,我对它知之甚少; Huey,类似于RQ,我对它知之甚少; WorQ在2016年进行了最后一次更新。 然后还有像Google's T...

53得票3回答
如何从非本连接自己的通道中恢复未确认的AMQP消息?

似乎我保持我的rabbitmq服务器运行得越久,未确认的消息就会越多。我希望重新排队它们。实际上似乎有一个amqp命令可以做到这一点,但它只适用于您的连接所使用的通道。我构建了一个小的pika脚本来尝试它,但我要么遗漏了什么,要么不能通过这种方式完成(那 rabbitmqctl 呢?)impo...

53得票2回答
使用Celery运行定时任务相比于使用crontab有什么优势?

考虑到Celery已经是运行任务队列的堆栈的一部分(即它不仅仅是为了运行cron而添加,这似乎是过度设计),那么它的“周期性任务”功能如何作为crontab的替代品是有益的呢?具体来说,以下是需要考虑的几个方面。 与crontab相比的主要优劣势 使用Celery比crontab更好的场景...

52得票9回答
如何优雅地重新启动Celery工作进程?

当发布一个新构建以更新工作程序中的代码时,如何优雅地重启celery工作者? 编辑: 我的意图是做类似于这样的事情。 工作者正在运行,可能正在将100 MB文件上传到S3 新的构建出现 工作者代码已更改 构建脚本向工作者发送信号 使用新代码启动新工作者 接收到信号的工作者完成现有任务后退出。