django-celery 相关问题

Django-celery为Django提供Celery集成。

如何在python django rest框架中始终收听Amazon sqs

我是python django rest框架的新手,我需要在框架中连续收听Amazon sqs。在哪里可以无限循环运行while或可以为此目的使用Celery [sqs]?提前谢谢。

回答 1 投票 0

芹菜节拍定期发送任务,但芹菜仅在生产中不时处理它们

我有一个使用redis集成了芹菜的django项目。我的芹菜工人在本地开发中表现出色,现在我正在生产中进行部署。在守护进程之前,我想看...

回答 1 投票 0

“鲜花经纪人”标签中不支持'redis'经纪人

我们正在使用Flower以Redis作为我们项目的经纪人来监控Celery的任务。当我们使用SSL将REDIS配置为代理时,在代理选项卡中,我们可以看到下一条消息:“'redis'代理是...

回答 1 投票 0

是否可以在django-tenant中使用django-celery-beat?

我正在使用芹菜安排任务。到目前为止,一切都很好,包括托管在AWS上。但是,我决定使用django-tenant将我的单个应用程序转换为多租户。这样,我可以...

回答 1 投票 0

SchedulingError:无法应用计划的任务下载器:参数必须为int,或具有fileno()方法

我已将djcelery和kombu.transport.django添加到django应用程序中。 settings.py:从.celery导入应用程序作为celery_app导入djcelery djcelery.setup_loader()BROKER_URL =“ redis:// abc:abc @ localhost:...

回答 1 投票 0

我如何基于传递给他们的参数查找Celery任务事件的任务ID?

我坚持认为自己很简单的事情。我试图确定是否可以找到给定已知参数集的所有任务ID。 Celery 4.4的API是否可以实现此功能,还是我必须编写自己的代码?

回答 1 投票 0

即使队列/并发被占用,Celery也应在呼叫时执行任务

我在Django中有一个celery应用,在其中我以特定的间隔定义了所有定期执行的明智任务。我已经用5个并发celery启动了celery worker -A appname worker --loglevel = info -B -c 5 ...

回答 1 投票 0

如何在Django芹菜中传递查询集

我正在尝试使用django构建Instagram机器人。我想实现django celery在后台运行任务。在这里,我面临一些问题。 celery的task.py从项目中导入了shared_task。...

回答 2 投票 0

如何在Django和Celery中配置多个代理?

[要求:Django使用RabbitMQ(Internal)和SQS / Kafka。这两个任务共享相同的DB / Django模型。截至2016年10月,Django设置仅支持一种代理配置。如何共享...

回答 1 投票 5

无法连接到代理错误,连接被对等方重置

[当我把芹菜拖尾时,我得到:消费者:无法连接到amqp:// guest:** @ [NEW_INSTANCE_IP]:5672 //:[Errno 104]由对等方重置连接。请在32.00秒内重试...当我拖尾我的花朵时,我...

回答 1 投票 0

等待所有任务在Celery python中运行

我正在python中使用celery来执行异步任务。我想捕获分配给所有工作人员的所有任务后的结果。为此,我正在使用.get()方法,但是问题是...

回答 1 投票 0

在执行任务期间从Celery工作人员捕获失败的任务

我目前正在celery(与RabbitMQ一起)中使用延迟方法来执行异步任务。这些任务分配给8个工作人员,在这些任务中,我正在执行数据库插入操作。 ...

回答 1 投票 2

已达到Django Celery Max DB连接

我正在django应用程序中的芹菜工作者上运行任务,其中每个任务大约需要1-2秒才能执行。通常,这些执行是很好的,但有时会执行,尤其是在Django ...

回答 1 投票 3

django celerybeat不调用task.py函数

基于本教程:https://www.merixstudio.com/blog/django-celery-beat/ celery.py来自__future__的文件代码__导入absolute_import,unicode_literals从celery导入os,从...导入芹菜...

回答 1 投票 0

Celery任务已永久启动(未重试)

我们在码头工人实例中使用芹菜工人。如果docker实例被杀死(可以更改docker并将其恢复),我们需要重试该任务。我的任务目前看起来像这样:@ app.task(...

回答 1 投票 0


在django上启动Celery worker时出错,错误10061无法建立连接,因为目标计算机主动拒绝了它

我正在使用django作为Web应用程序的框架。为了使用celery,我安装了django-celery,celery和celer [redis]。当它尝试启动芹菜工作者时,它显示错误...

回答 1 投票 0

Celery Signals与Django Signals

芹菜信号与同步的Django信号不同吗?只是好奇例如芹菜的task_success信号与django的post_save信号。

回答 1 投票 0

芹菜工作者的任务处理被延迟

[借助芹菜,我为Redis创建了侦听器,以将所有写入事件都获取给Redis。根据事件,我将触发celery任务,以将数据从Redis迁移到DB。我正在使用事件池...

回答 1 投票 0

仅在完成所有任务后才保存任务结果

我想监视/报告任务状态,但是仅在完成所有任务后才保存任务。我希望它们一开始就被保存。 '''在我的队列项目内部'''celery.py来自__future__ ...

回答 1 投票 0

最新问题
© www.soinside.com 2019 - 2025. All rights reserved.