celery 相关问题

Celery是Python的分布式任务队列框架,用于异步和并行执行。

芹菜组按顺序运行任务,而不是并行运行。

我正在学习芹菜组函数 @celery_app.task def celery_task(): import time time.sleep(30) print('task 1') @celery_app.task def celery_task2(): import time time.sleep(10) ...

回答 1 投票 0

Django芹菜设置导入问题

我试图创建一个celery文件,并通过...celery -A myapp worker -l info运行,但是我得到了错误,文件 "productionpythonenvprojectlibpython2.7site-packagesconfigurations..."。

回答 1 投票 5

Django定期任务芹菜

我是Django和Celery的新手。请帮助我,我不明白,它是如何工作的。我想在我的控制台中看到 "Hello world "每1分钟。 tasks.py from celery import Celery from celery.schedules ...。

回答 1 投票 0

Django.CeleryBeat 服务器上有Supervisor的CeleryBeat没有安排定期任务。

我在本地主机上的Django 1.8.5 + Celery 3.1.18都能正常工作,并有周期性的任务设置,但在服务器上(Ubuntu 14.04),我需要额外的文件celerybeat.conf(首先是celery.conf)来实现周期性的任务。但是在服务器上(Ubuntu 14.04),我需要额外的文件celerybeat.conf(第一个是celery.conf)来进行周期性的任务设置。

回答 1 投票 0

Celery, Django 和 @shared_task

我试图将芹菜和Django结合起来使用;我的一个应用程序中有一个任务,我想用芹菜来运行它。不幸的是,我无法让芹菜找到任务,而是得到了...。

回答 1 投票 1

基于Django文件系统文件的缓存有5-10%的时间无法写入数据。

我们正在用Django Celery做后台数据处理,把一个CSV文件(最大15MB),转换成dict数据列表(其中还包括一些Django模型对象),然后把它拆分......

回答 1 投票 3

celery 4.4.2 和 django 3.0.2 引起 self.notregistered 错误,但在 python manage.py shell 中调用该函数却能正常工作。

我试图将芹菜添加到我的django项目中。当我从manage.py shell中运行它时,一切都很好,我的芹菜工人返回add()函数的结果。

回答 1 投票 0

消费者。无法连接到amqp:/user:**@rabbit1:5672/: 未能解析经纪人主机名。

我仔细阅读了非常类似的stackoverflow问题,并将我的代码改成了现在的样子。我仍然得到无法解析broker hostname的错误。如果我只是使用amqp:user:mypass@locahost:...。

回答 1 投票 0

deamon celery启动失败 "模块blah未找到 "或 "ImportError: attempted relative import with no known parent package"

我已经在ubuntu 18.04 lts上运行python 3.6的venv下安装了flask与apache(wsgi),并成功导入了其他模块。包括芹菜与rabbitmq。我按照这个指导对Celery......

回答 1 投票 -1

芹菜任务未检测到来自子进程的错误。

我有以下的任务,使用Popen运行一个python脚本(我已经尝试过用check_output调用,结果相同) @app.task def TaskName(filename): try: proc = subprocess...。

回答 1 投票 0

docker-compose问题 - Celery容器无法访问DB容器

Regards 我一直在研究一个Django应用程序,它在Redis、PostgreSQL、Celery、RabbitMQ上运行。我写了一个docker-compose来在各自的容器中运行所有这些服务。这里...

回答 1 投票 0

什么时候用芹菜团扇出与延时?

想在这里找出最佳实践,因为我正在学习芹菜。我想在另一个工作中扇出一堆小工作。我理解群组是一个很好的方法,从一堆 ...

回答 1 投票 1

控制芹菜工的消耗速度

我正在尝试在我的Django应用中设置Celery。这个应用会让用户调用一些API并获得响应。但是这个API有限制,只允许用户每秒钟调用不超过一次。

回答 1 投票 0

| Celery

In production server, I am getting the following error in celery console which never happened before. I found the same issue in other posts, they are saying give valid url but the url i have given in ...

回答 1 投票 0

Celery是否使用结果后端结合链和组的方式?

在我的Python项目中,我想使用芹菜来创建任务的管道:一些任务将被分组,这个组是链的一部分。管道的模式: task_chain = chain( group( ...)

回答 1 投票 0

如何为部署在Celery集群上的所有任务分配相同数量的资源?

为了在科学实验中比较和对比三种不同算法的性能,我打算使用Celery调度器。这些算法由三种不同的工具实现。...

回答 1 投票 0

如何通过编程告诉Celery将所有日志信息发送到stdout或stderr?

如何以编程方式开启芹菜日志?从终端来看,这样做很好: celery worker -l DEBUG 当我调用 get_task_logger(__name__).debug('hello')时,我可以看到消息出现......

回答 2 投票 10

阅读文档本地安装。Celery ValueError:信号只在主线程中工作

我安装了一个本地的readthedocs,当我试图导入一个项目时,得到一个ValueError异常。我的版本是5.1.0,在Debian buster上运行python 3.6和celery 4.1.1 (从需求......

回答 1 投票 1

Django芹菜日志最佳实践

我试图让Celery日志与Django一起工作。我在settings.py中设置了日志记录到控制台(由于我是在Heroku上托管的,所以工作正常)。在每个模块的顶部,我有:import ...

回答 4 投票 64

芹菜任务运行时间不超过30mins。

现在有一个要求,芹菜任务开始执行后,超过30分钟后会自动结束,或者杀死任务(如何杀死)。这就意味着,最大运行 ...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.