Django-celery为Django提供Celery集成。
我试图了解celery是如何工作的,在我的Django应用程序task.py文件中,我创建了一个任务:@ celery.shared_task(default_retry_delay = 2 * 60,max_retries = 2)def my_task(param1,param2)。 。
为什么我创建的模型实例,从后来直接启动的芹菜任务中查询,未找到?例如:#app.views model = Model.objects.create()#我在...中创建我可爱的模型
文件结构proj / proj / celery.py(和其他文件)/ sitesettings / tasks.py(和其他文件)celery.py app = Celery('mooncake',broker_url ='amqp://')app ....
我在django驱动的网站上使用Celery和Celerybeat。服务器操作系统是Ubuntu 16.04。通过使用celerybeat,每10分钟由芹菜工人完成一项工作。有时候工人没有......
我想使用Celery来异步运行我的任务,我遇到了一些麻烦。我想通过导出方法创建一个数据文件。上下文:用户可以导出搜索...
我用Django阅读了很多关于Celery的文档,我试图创建我的第一个cron任务。目标:此任务应该能够执行每天在11清理特定表的功能:...
目前正在使用我的django应用程序进行生产,我遇到了Celery的问题,其中任务有时需要1-2秒,但有时需要15-25秒。我的应用程序是一个聊天机器人相关的应用程序,所以它需要...
我想根据Celery和Redis用我的Django应用程序提出一个问题。正如我将进一步详细解释,我对这些应用程序有一些随机问题。我的环境:我......
使用django-anymail配置django-celery-email
我正在使用django-anymail(sendgrid)在我的网络应用程序中发送电子邮件。我想让电子邮件以异步方式发送,而不让用户等待一段时间。所以,我怎样才能配置django -...
我想验证为芹菜任务设置时间限制是否有效。我目前的配置如下: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()。但我得到*** ......