如何正确配置和运行远程celeryworker？
我是芹菜新手，可能做错了什么，但我已经 花了很多时间试图弄清楚如何配置 celery 正确。 所以，在我的环境中，我有 2 个远程服务器；一个是主要的（…
如何在python中使用celery清除特定队列的所有任务？
如何在python中使用celery清除特定que的所有计划和正在运行的任务？这些问题似乎很直接，但要补充的是，我不是在寻找命令行代码 ，我有以下行，它定义…
芹菜 + RabbitMQ，一些 AMQP 临时队列不会过期
我有一个 celery +rabbitmq 设置和一个繁忙的 django 站点，在 celery 设置中我有这个配置： CELERY_RESULT_BACKEND = "amqp" CELERY_AMQP_TASK_RESUL…
为姜戈预订芹菜 +兔子MQ？
Closed. This question does not meet Stack Overflow guidelines. It is not currently accepting answers. 要求我们推荐或查找工具、库或最喜欢的…
CELERY_ROUTES - 如何根据任务名称进行路由
我试图让 celery 根据任务名称路由任务...基本上，我有名为“worker.some_name”和“web.some_name”的任务，并且我使用两个不同的队列，称为worker和…
Celery - 安排从特定时间开始的周期性任务
安排从特定日期时间开始的定期任务的最佳方法是什么？ （考虑到我需要安排大约一百个远程 rsync，我没有使用 cron， 我计算远程与本地偏移量，并且需…
使用 memcached 设置/获取对象
在 Django Python 应用程序中，我使用 Celery（任务管理器）启动作业。当每个作业启动时，它们都会返回一个对象（我们将其称为 X 类的实例），让您可…
如果任务没有运行超过 10 分钟，如何重新安排任务？
我有 task:recursive_task 它将安排相同的任务在 5 秒后执行，但如果由于某种原因该任务崩溃，则需要再次重新运行。 我几乎捕捉到了所有场景，但你永…
创建一个一次只执行一次的 Celery 任务
我已经阅读了 Celery 文档中的相应文章（Cookbook :: 创建任务），但是我并不完全喜欢建议的解决方案。我有很长的运行任务（从 15 分钟到 1 小时，甚…
在不暂停服务的情况下将新代码部署到生产 celery 集群中的可靠方法
我有一些 celery 节点在生产中使用rabbitmq 运行，并且我一直在处理服务中断的部署。我必须关闭整个站点才能将新代码部署到 celery。我将每个子任务的…
Celery period_task 并行运行多次
我有一些使用 Celery 线程的非常简单的周期代码；它只是打印“Pre”和“Post”并在中间休眠。它改编自这个StackOverflow问题和此链接网站 from celery…
