芹菜在due_date上发送电子邮件
日期有所不同。 根据模型中使用芹菜中的截止日期将电子邮件发送给用户，Due_date与创建任务 models.py 的 class Task(BaseModel): name = models.Char…
我想路由2个不同的Celery_BROKER_URL
我想将2种不同的芹菜broker_url用于2个不同的IP，并且特定任务应在另一个URL中进行（ex -redis：//127.0.0.2：6379）。 环境文件 CELERY_TASK_TRACK_S…
限制不同数量的芹菜任务组的工人
对于不同的芹菜工作组，我们如何以不同的方式限制工人的数量。 这是有关如何将不同芹菜任务组合在一起的很好的参考： https://sayari3.com/articles/1…
芹菜＆＃x2B; REDIS如何基于最低时间戳以相同的优先级运行任务
我已经在芹菜中定义了一个任务，并使用烧瓶框架被称为。我看到芹菜能够在工作节点上执行任务。现在可以说，一些API以这种方式称为任务。 timestamp, t…
芹菜：如何关闭/超时的芹菜工人儿童/过程
我正在运行芹菜工人 - 同意= 10 。因此，在我的环境中，Parallele中有10个过程。 执行任务并返回时，我希望我的服务器告诉（Worker）过程以自杀。然后…
芹菜限制每个用户运行的任务数量
我的芹菜任务看起来像这样： @app.task(name='task_one') def task_one(user_id, *args, **kwargs): # Long running task 此任务是在用户提交表单时在…
芹菜任务_reject_on_worker_lost do do do do do do do dodis do redis作为消息经纪
我目前正在使用Redis的芹菜和6.2.6版的5.2.6版。当我打开 关于如何与Message Broker实现相同行为的任何指示？…
是否有与芹菜有关的问题的修复程序？ https://github.com/celery/celery/issues/3519
芹菜似乎正在选择我的旧代码和新代码。我尝试清理缓存，清除经纪人队列（REDIS），重新启动芹菜等。但是它们似乎都没有解决此问题。 对于上下文，我们…
升级芹菜4.xx到django app中的5.xx -execute_from_commandline（）替换
4.xx中的用法如下： from tenant_schemas_celery.app import CeleryApp class TenantCeleryApp(CeleryApp): def create_task_cls(self): return self.…
动态更改芹菜节拍时间表参数
我从.env文件中获得计划值。有时在.env文件中更改。 是否可以更改已经运行的芹菜节拍任务的时间表值？ 我的芹菜.py： import os from celery import C…
如何并行运行多个芹菜任务（使用组）？
我是芹菜的新手。我想并行运行Demo_task，但是它依次运行任务，而不是并行运行。请让我知道我做错了什么。 import time from celery import Celery fr…
kombu.exceptions.encodeerror：类型集的对象在芹菜中不可用JSON序列化
我正在使用快速的API，在其中使用芹菜进行任务队列预测。每当我进行预测并试图返回响应时，我都会收到 500未记录的错误：内部服务器错误并从Docker Lo…
芹菜和弦因valueerror的失败：没有足够的价值打开包装（预期2，得到1）
我正在运行 ubuntu 的 docker 容器中运行 celery v5.2.3。 在这里，我试图让芹菜和弦发挥作用，但我所做的每一次尝试都会给我带来： File "/usr/local…
