Django-celery为Django提供Celery集成。
我正在尝试将芹菜与Django结合使用。因此,我遇到了autodiscover_tasks(),但我不确定如何使用它们。芹菜工人获得其他应用程序添加的任务(...
在Django中使用Celery Task创建对象(在ViewSet类中)
你好,我遇到了一个我自己无法解决的问题。我试图在create内调用函数create_with_celery,但没有成功。如何使用适当的参数调用create.delay? ...
ImportError:curl客户端需要pycurl库Docker + Django
我正在对Django 2.2应用程序进行docker化,并使用Pipenv进行环境管理。我想将SQS用作Django celery的代理。我已经使用Pipenv [packages] ... ...
我创建了一个运行celery的systemd进程。我将并发设置为1,因为我需要执行在先进先出(FIFO)队列中运行的任务。如果我需要停止芹菜进行维护,如何...
我对芹菜有新手经验。我已经写了许多任务,既有计划任务,也有一份延迟工作,但这就是事实。我遇到了一个我想创建一个任务的问题,......>
使用数据库调度程序的Django Celery Beat?任务似乎从未完成
我需要在Django Admin的Django Celery Beat包https://django-celery-beat.readthedocs.io/en/latest/中使用DatabaseScheduler的助手。我要执行以下操作...
如何在停止Redis之后继续执行芹菜队列,然后稍后再启动它?
我正在运行一个Django应用程序,该应用程序使用Celery并将Redis服务器用作工作程序来运行异步任务。我需要能够停止整个基础结构并在没有...
芹菜可以处理多个并发速率限制吗?我的任务每秒可以运行不超过10次,每天不超过100,000次,但我将文档视为仅支持...
Celery GroupResult和ResultSet有什么区别?
文档只提到GroupResult是“类似于ResultSet,但具有关联的ID。”具体来说,如果唯一的区别是...
我已经创建了一个使用共享任务实现一些文本操作的通道,该共享任务将响应返回到通道层。 #consumers.py import json从asgiref.sync import中导入pdb ...
是否可以在不通过触发它的方法传递时间参数的情况下签入任务函数,让我说我有@task(name =“ example.task.task1”)def task1(arg1,arg2):#我想要到...
我们使用Celery在我们的Python Django应用程序中管理任务。我们还将Django structlog用于Celery打印的日志消息。我们通过Logstash将这些消息摄取到ElasticSearch,并注意到...
Django Celery Task中的Elasticsearch索引编制
我正在构建Django网络应用程序以存储文档及其相关的元数据。元数据的大部分将存储在底层的MySQL数据库中,并将OCR的文档文本编入索引...
如何在内存中加载对象并在Celery worker的不同执行之间共享?
我在3台集群计算机上安装了celery + rabbitmq。我还创建了一个任务,该任务根据文件中的数据生成一个正则表达式,并使用该信息来解析文本。但是,...
Celery Worker命令'包装方法'对象没有属性'__module __'
当前正在尝试为我的django应用程序启动工作程序,不幸的是,我收到此错误:PS C:\ Users \ User \ Users \ Documents \ Codes \ highlightreel> celery -A Highlightreel Worker -l info Traceback(...
我正在一个团队中为我的大学从事一个项目,我主要从事前端和一些基本的django模型的工作,因此我对django-celery并不那么熟悉和雄辩,我也... ...
我需要您对我面临的挑战发表意见。我正在建立一个网站,使用Django作为后端,使用PostgreSQL作为我的数据库,使用GraphQL作为我的API层,使用React作为我的前端框架。网站是...
Django Celery Beats Package添加自定义模型字段
我正在使用项目(https://pypi.org/project/django-celery-beat/)中的pypi django_celery_beats包,并且处于将字段添加到...