Django-Celery 进度条
我使用： Celery Django-Celery RabbitMQ 我可以在Django管理页面中看到我的所有任务，但目前它只有一些状态，例如： 已接收(RECEIVED) 重试(RETRY) 撤销(REVOKED) 成功(SUCCESS) 开始(STARTED) 失败(FA...
Celery任务状态始终为pending
我对celery和django都比较陌生，所以请原谅我的一个知识缺乏。我正在尝试运行一个测试来进行一些计算，并等待测试结束，以确保得到正确的答案。 以下是我的代码： 在app/tests.py中：from tasks import * c = calculate.apply_async...
如何调试“无法从客户端接收数据：连接被对等方重置”错误
我正在Ubuntu-12.04上运行django-celery应用程序。 当我从Web界面运行celery任务时，我会收到以下错误，取自postgresql-9.3日志文件（日志的最高级别）：2013-11-12 13:57:01 GMT tss_usr 8113 LOG: could n...
重试失效或失败的任务（Celery、Django 和 RabbitMQ）
有没有一种方法可以确定是否丢失了任何任务并重试它？ 我认为丢失的原因可能是调度程序错误或工作线程崩溃。 我打算重试它们，但不确定如何确定需要重试哪些任务？ 如何自动进行此过程？我可以使用自己的定制调度程序来创建新任务吗？ 编辑：我从文档中发现，RabbitMQ永远不会丢失任务，但是...
如何推迟执行Celery任务？
我有一个小脚本，它将任务加入队列以进行处理。该脚本会执行大量数据库查询以获取应该加入队列的项目。我面临的问题是，当脚本将任务加入队列时，celery工作进程立即开始拾取任务。这是正确的，也是celery预定的方式，但这经常会导致我的脚本和celery工作进程之间死锁。 是否有一种方法可以从脚...
如何使用AWS Elastic Beanstalk扩展Django应用程序并运行Celery Worker？
如何在 AWS Elastic Beanstalk 上使用 Django，同时只在主节点上通过 celery 运行任务？
Django celery 任务：新创建的模型不存在。
我创建的模型实例，在随后直接启动的celery任务中查询时，为什么找不到？例如:# app.views model = Model.objects.create() # I create my lovely model in a view from app.tasks import M...
Celery: 工作进程数 vs 并发数
一个并发数为4的工作者和两个并发数为2的工作者在同一个队列上有什么不同？ 谢谢。
如何在多个Django应用程序中使用celeryd作为守护进程？
我刚开始使用django-celery，希望将celeryd设置为守护进程。然而，说明文档似乎暗示每次只能为一个站点/项目进行配置。celeryd是否可以处理多个项目？或者它只能处理一个项目？如果是这种情况，有没有一种干净的方式为每个配置自动启动celeryd，而不需要为每个配置创建单独的in...
Celery：在特定时间间隔后执行任务
我希望在用户注册后精确48小时发送电子邮件。如何使用celery实现？如果我创建一个定期任务来发送电子邮件，我将不得不决定执行该任务的特定时间段。我不想每秒运行celery任务来检查是否需要发送电子邮件。