Django-celery为Django提供Celery集成。
我想验证为芹菜任务设置时间限制是否有效。我目前的配置如下:CELERYD_TASK_SOFT_TIME_LIMIT = 30 CELERYD_TASK_TIME_LIMIT = 120 ...
我正在为我的django项目使用django-celery。最后一天我更改了计算机的主机名(我正在使用Ubuntu 12.04,编辑文件'/ etc / hostname'),下次重启后django-celery失败了...
在on_failure或on_sucesss钩子中使用请求库会导致任务无限期地重试
这就是我所拥有的:导入youtube_dl#以防这个问题类ErrorCatchingTask(Task):#Request = CustomRequest def on_failure(self,exc,task_id,args,kwargs,einfo):#If if ...
我使用celery,supervisor和flower supervisor conf:command = / web / venv / bin / python manage.py celeryd -E -l info -c 2 --maxtasksperchild = 1 -Ofair directory = / web / stdout_logfile = / web / log / ...
django celery守护进程确实有效:它无法创建pid文件
我无法初始化mi celeryd和celerybeat服务,我在另一个环境中使用相同的代码(从一开始就配置所有内容),但这里不起作用。我认为这是通过权限,但我不能......
我正在使用Celery来管理异步任务。然而,偶尔芹菜过程会失效,导致任何任务都无法执行。我希望能够检查芹菜的状态......
我一直在阅读django-celery试图找到一种清理celery_taskmeta的原生方式,所以这个表在生产环境中不会长得太多。什么也都找不到。我应该做...
这是在为用户刷新访问令牌的上下文中。假设我们有函数refresh_user_token,它以用户身份接收CustomUser对象。 def refresh_user_token(user):...... ......
我正在研究一个使用Celery异步运行某些任务的Django应用程序。我尝试使用Apache Bench执行负载测试并检查响应时间。从我能从中得出的......
启动后立即访问django-celery-results TaskResult
我在Django视图中执行了几个Celery任务(更具体地说,在Django Rest Framework的perform_create方法中)。我想要实现的是立即(即...
一些Celery任务有效,另一些则是NotRegistered
我按照Celery Django教程和我在示例中看到的任务(add,mul)完美地为我工作。当我执行res = add.delay(1,2)时,我得到正确的响应; res.get()。但我得到*** ......
我正在使用Celery与Amazon SQS,我在日志中看到了大量这些内容:[2013-06-19 19:03:42,890:ERROR / MainProcess]池回调引发异常:KeyError('8a8fe51c-b69f-498e- 95c1-f037e2f2d4a8' ,...
Celery任务返回AsyncResult而不是Dictionary
我正面临着这个问题。我正在使用celery进行异步任务。当我运行worker(RabbitMQ)时,shared_task成功运行但没有按预期返回结果。我想要归还......
如何将在tasks.py之外定义的函数转换为Celery任务,并使Celery工作程序在Django中处理它
我试图在我的Django项目中使用Celery说“MySite”。我的目录结构如下mysite - applications - api -tasks.py -urls.py -apps.py -__init__.py ...
我正在尝试用django建立芹菜。所有设置都已设置,如果我开始任务manuelly它正在工作。 (所有发生在我的本地开发服务器上)mytask.apply_async()然后我尝试设置...
Django和Celery - 在更改后将代码重新加载到Celery中
如果我在芹菜运行时对tasks.py进行了更改,是否有一种机制可以重新加载更新的代码?或者我必须关闭芹菜重新装载?我读过芹菜有--autoreload ...
Celery任务在任务成功后调用自己而没有celerybeat
我想在当前任务完成后的每30分钟偶尔调用我的芹菜任务,但由于任务从远程服务器下载文件,有时需要的时间比预期的要长。所以我 ...
在celery中,当任务入队时,将上下文元数据从发送者进程传递给worker的适当方法是什么?
当任何celery任务入队时,我想添加工作人员能够使用的上下文元数据。以下代码示例有效,但我希望有一个合适的芹菜式解决方案。 ...
Celery - Heroku上的Django Web应用程序与Celery工作进程 - 我怎样才能追逐这个内存泄漏?
我正在运行heroku logs --ps celery --tail并看到以下内容:错误R14(超出内存配额)进程运行mem = 650M(127.1%)DEBUG设置为False。芹菜版是3.1.9我没有......
根据某些型号日期字段运行Django Celery Beat taks
有没有办法将Django芹菜任务与数据库中保存的每条记录联系起来?例如,如果我希望每个用户收到一封电子邮件,具体取决于用户想要的日期。也许我错了......