芹菜链没有触发第二任务
我有两个芹菜任务，应严格运行。 def celery_run_tasks(): chain(task_one.s(arg1, arg2), task_two.s(arg1, arg2)).apply_async() 因此，第一个任务…
芹菜时间表每10秒运行一次
，我需要每10秒钟运行一次芹菜，但我必须这样工作： 10：27-弗里斯特运行 10：30-第二次运行 我的代码现在这样： #task.py from celery import Celery…
DRF和芹菜：filenotfounderror：[errno 2]没有此类文件或目录
这在我的本地部署上正常工作，但在云部署上效果不佳。 with open(file_path, "wb+") as fp: for chunk in file: fp.write(chunk) result = upload.del…
烧瓶，芹菜，pytest和apply_async倒计时混乱
我敢肯定这是在某个地方注明的，但是我在旋转我的车轮，所以希望这里有人可以提供帮助。 我正在使用一个使用芹菜的烧瓶应用程序，并且正在使用Pytest…
如果我没有在Python的芹菜中设置泳池选项，为什么队列会丢失？
我只是在Python中设置并使用芹菜。但是芹菜队列似乎已经迷失了，所以我正在检查它。 例如，如果有一个过程可以完成任务A 并将队列发送到任务B ，则 a …
芹菜：如何关闭/超时的芹菜工人儿童/过程
我正在运行芹菜工人 - 同意= 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实现相同行为的任何指示？…
使用全局时，Python运行threadpoolexecutor crosswise
在我的Python应用程序中，我使用芹菜处理长期运行的任务（其中许多）。在我的一项任务中，我有以下代码将段上传到S3存储，请一般可以看一下， if not …
是否有与芹菜有关的问题的修复程序？ https://github.com/celery/celery/issues/3519
芹菜似乎正在选择我的旧代码和新代码。我尝试清理缓存，清除经纪人队列（REDIS），重新启动芹菜等。但是它们似乎都没有解决此问题。 对于上下文，我们…
Django生成Excel并用芹菜和RabbitMQ保存为对象
我正在使用Django 2.2.5，芹菜5.2.6和Rabbitmq，并且是最后2个新手。 我想生成Excel表并将其存储在新创建的对象中（不下载）中，这是我做了什么： pro…
Django如何在另一个请求中处理长期请求？
关于Django在另一个请求（3sec）中处理长期请求（50秒）的问题。 我有一个发布请求将返回用户的一些信息，在此请求中，将在同一应用中调用另一个API，…
