Django-celery为Django提供Celery集成。
如何在python django rest框架中始终收听Amazon sqs
我是python django rest框架的新手,我需要在框架中连续收听Amazon sqs。在哪里可以无限循环运行while或可以为此目的使用Celery [sqs]?提前谢谢。
我有一个使用redis集成了芹菜的django项目。我的芹菜工人在本地开发中表现出色,现在我正在生产中进行部署。在守护进程之前,我想看...
我们正在使用Flower以Redis作为我们项目的经纪人来监控Celery的任务。当我们使用SSL将REDIS配置为代理时,在代理选项卡中,我们可以看到下一条消息:“'redis'代理是...
是否可以在django-tenant中使用django-celery-beat?
我正在使用芹菜安排任务。到目前为止,一切都很好,包括托管在AWS上。但是,我决定使用django-tenant将我的单个应用程序转换为多租户。这样,我可以...
SchedulingError:无法应用计划的任务下载器:参数必须为int,或具有fileno()方法
我已将djcelery和kombu.transport.django添加到django应用程序中。 settings.py:从.celery导入应用程序作为celery_app导入djcelery djcelery.setup_loader()BROKER_URL =“ redis:// abc:abc @ localhost:...
我如何基于传递给他们的参数查找Celery任务事件的任务ID?
我坚持认为自己很简单的事情。我试图确定是否可以找到给定已知参数集的所有任务ID。 Celery 4.4的API是否可以实现此功能,还是我必须编写自己的代码?
我在Django中有一个celery应用,在其中我以特定的间隔定义了所有定期执行的明智任务。我已经用5个并发celery启动了celery worker -A appname worker --loglevel = info -B -c 5 ...
我正在尝试使用django构建Instagram机器人。我想实现django celery在后台运行任务。在这里,我面临一些问题。 celery的task.py从项目中导入了shared_task。...
[要求:Django使用RabbitMQ(Internal)和SQS / Kafka。这两个任务共享相同的DB / Django模型。截至2016年10月,Django设置仅支持一种代理配置。如何共享...
[当我把芹菜拖尾时,我得到:消费者:无法连接到amqp:// guest:** @ [NEW_INSTANCE_IP]:5672 //:[Errno 104]由对等方重置连接。请在32.00秒内重试...当我拖尾我的花朵时,我...
我正在python中使用celery来执行异步任务。我想捕获分配给所有工作人员的所有任务后的结果。为此,我正在使用.get()方法,但是问题是...
我目前正在celery(与RabbitMQ一起)中使用延迟方法来执行异步任务。这些任务分配给8个工作人员,在这些任务中,我正在执行数据库插入操作。 ...
我正在django应用程序中的芹菜工作者上运行任务,其中每个任务大约需要1-2秒才能执行。通常,这些执行是很好的,但有时会执行,尤其是在Django ...
基于本教程:https://www.merixstudio.com/blog/django-celery-beat/ celery.py来自__future__的文件代码__导入absolute_import,unicode_literals从celery导入os,从...导入芹菜...
我们在码头工人实例中使用芹菜工人。如果docker实例被杀死(可以更改docker并将其恢复),我们需要重试该任务。我的任务目前看起来像这样:@ app.task(...
在django上启动Celery worker时出错,错误10061无法建立连接,因为目标计算机主动拒绝了它
我正在使用django作为Web应用程序的框架。为了使用celery,我安装了django-celery,celery和celer [redis]。当它尝试启动芹菜工作者时,它显示错误...
芹菜信号与同步的Django信号不同吗?只是好奇例如芹菜的task_success信号与django的post_save信号。
[借助芹菜,我为Redis创建了侦听器,以将所有写入事件都获取给Redis。根据事件,我将触发celery任务,以将数据从Redis迁移到DB。我正在使用事件池...
我想监视/报告任务状态,但是仅在完成所有任务后才保存任务。我希望它们一开始就被保存。 '''在我的队列项目内部'''celery.py来自__future__ ...