-
1 votesanswersviews
Celery不会在django 1.11和芹菜4.0.0或4.1.0中发现shared_tasks
我在我的项目中有一个这样的布局:(正如文档所说的那样) /zonia /backend __init__.py celery.py ... /musics tasks.py ... ... 在 init .py中: from __future__ import absolute_import, unicode_li... -
0 votesanswersviews
芹菜 Worker 只工作一次
完整步骤: 开始django 开始一个芹菜 Worker python manage.py celery worker --app = celery_worker:app -Ofair -n W1 上传一个url列表文件,循环url列表发送每个url到一个任务 fetch_article Worker 工作 上传另一个url列表文件 Worker 没有行动 view... -
0 votesanswersviews
(Django-Celery错误)ImportError:没有名为myproject的模块
我是第一次使用Django-Celery . 当我尝试运行以下命令时: celery -A MyProject worker -l info 我收到此错误消息: ImportError: No module named MyProject MyProject / MyProject / init .py: from __future__ import absolute_import, un... -
24 votesanswersviews
Django和Celery的例子:周期性任务
我一直在与Django / Celery文档争论一段时间,需要一些帮助 . 我希望能够使用django-celery运行Periodic Tasks . 我已经在互联网(和文档)周围看到了几种不同的格式和模式,以了解如何使用Celery实现这一目标... 有人可以帮助创建,注册和执行django-celery定期任务的基本功能示例吗?特别是,我想知道是否应该编写一个扩展PeriodicTask类并... -
2 votesanswersviews
尝试运行celeryd_multi时出现属性错误
我试图以手动( python manage.py celeryd_multi... )或通过init.d作为守护进程启动celeryd_multi时得到一个 AttributeError: 'module' object has no attribute 'getrlimit' . 我可以用 python manage.py celeryd 手动启动芹菜 从/ etc / default... -
0 votesanswersviews
芹菜和芹菜之间的混乱
我已经在我的django应用程序中成功安装了芹菜和django芹菜 . 我已经学习了很多教程,以便了解它 . 有些人像芹菜一样开始工作: python manage.py celery worker --loglevel=info 其他人用芹菜 d 开始: python manage.py celeryd –-verbosity=2 –loglevel=DEBUG 我有2个问题请: 我应该... -
1 votesanswersviews
在Celery Redis中使用Django Cache会导致Celery崩溃
我有一个在Heroku上运行的Python应用程序,我有Redis和Celery工作但是当我尝试配置Django Cache(这使我的应用程序运行得更快)时,它会导致Celery不断崩溃 . 这是我在启用Django Cache后在日志中看到的内容: » 20 Jan 2016 14:13:15.731 2016-01-20 20:13:15.420592+00:00 app web.1 - - ... -
8 votesanswersviews
Django-celery和RabbitMQ没有执行任务
我们有一个 Django 1.3 应用程序 django-celery 2.5.5 已经在 生产环境 中运行了一个月,但突然之一芹菜任务现在无法执行 . RabbitMQ代理和Celery工作程序在单独的机器上运行,celeryconfig.py配置为使用该特定RabbitMQ实例作为后端 . 在应用程序服务器上,我尝试通过 python manage.py shell 手动触发芹菜任务 . 实际... -
1 votesanswersviews
使用Celery将消息发布到RabbitMQ中的Exchange
我写了一个Django-Project,它通过 my_task.delay() 提示不同的任务异步 . 问题是随着项目变得越来越大,正确地路由任务真的很困难 - 我开始编写的任务只是为了组合不同的任务,这使得代码在一段时间后变得混乱 . 当我阅读一些RabbitMQ文档时,我遇到了一个解决方案,它可以更好地构建我的项目,依赖于Exchange . 交换可以将消息发布到Cosumer可以使用它的多个... -
1 votesanswersviews
有没有办法在django-celery中验证经纪人的SSL证书?
我正在使用django-celery通过SSL连接到RabbitMQ代理(使用BROKER_USE_SSL设置) . 有办法: Build 连接时验证代理的证书 . 配置客户端证书给我们以 Build 连接 . RabbitMQ方面正常工作,但我不知道如何为此配置Celery,我也没有在Celery的文档中找到任何内容 . 设置CELERY_SECURITY_KEY,CELERY_SE... -
4 votesanswersviews
Celery:使用Redis作为result_backend,使用RabbitMQ作为消息代理
我是Celery,Redis和RabbitMQ的新手 . 目前,我正在使用RabbitMQ作为消息代理,并且在配置中设置了nothings . (使用Django,MySQL) 我想知道是否可以在后端使用Redis作为结果存储,同时,RabbitMQ作为消息代理 . 我知道的事情只是添加一些设置, CELERY_RESULT_BACKEND = "redis" -
13 votesanswersviews
Celery - RabbitMQ中的消息可以同时由两个或更多 Worker 消费吗?
也许我在愚蠢地提出这个问题,但在进一步开展工作之前,我需要围绕基本概念 . 我正在处理几千个RSS源,使用多个Celery工作节点和RabbitMQ节点作为代理 . 每个订阅源的URL都作为消息写入队列中 . 工作人员只是从队列中读取URL并开始处理它 . I have to ensure that a single RSS feed does not get processed by two... -
2 votesanswersviews
使用Celery以不同的优先级运行相同的任务
所以我有一个非常有趣的场景,我希望以不同的优先级运行相同的Celery任务,具体取决于它的调用位置 - 例如,我想为优先级高的用户运行任务,优先级高于非高级用户 . 使用文档,我能够设置多个队列,并且能够通过将所有.delay调用更改为.apply_async调用并传入指定优先级队列的其他routing_key来使其工作 . 问题是必须在很多不同的地方做到这一点 . 有没有更好的方法来处理这个?我... -
1 votesanswersviews
如何在ubuntu服务器上守护django芹菜周期性任务?
在localhost上,我使用这些语句来执行任务和工作程序 . 运行任务:python manage.py celery beat Run worker:python manage.py celery worker --lvelvel = info我使用了otp,rabbitmq server和django-celery . 它工作正常 . 我在ubuntu服务器上上传了这个项目 . 我想要守护这... -
2 votesanswersviews
Celery-Django作为守护进程:ImportError:没有名为django.conf的模块
我正在研究使用Celery的Django项目 . 在开发过程中,Celery工作正常 . 我的任务正在开发中正确安排 . 对于守护进程,我根据文档创建了 /etc/init.d/celeryd 和 /etc/defaults/celeryd . 当我输入命令 bash -x /etc/init.d/celeryd start 时,我收到错误N o module named django.con... -
2 votesanswersviews
django-celery作为一个守护进程:不工作
我有一个用django,芹菜和rabbitmq写的网站项目 . 单击按钮时会调用“.delay”任务(任务创建新文件夹) . 当我使用manage.py运行芹菜时,芹菜的一切正常(调用.delay任务,并创建一个新文件夹): python manage.py celeryd 但是,当我将celery作为守护程序运行时,即使没有错误,也没有执行任务(没有创建文件夹) . 我有点跟随教程:http:/... -
3 votesanswersviews
daemonizing芹菜过程celeryd-multi未找到
我正在尝试在一个virtualenv里面运行django的celery进程守护进程 . 我将celeryd文件从https://github.com/celery/celery/tree/master/extra/generic-init.d复制到/etc/init.d/ 然后我创建了一个包含http://ask.github.io/celery/cookbook/daemonizing.html... -
0 votesanswersviews
django-celery进程达到100%且任务未执行
我在Ubuntu 12.04服务器上使用最新版本的django-celery和RabbitMQ Worker . 我在一个月前开始遇到芹菜任务的问题,我无法弄清楚问题是什么 . 我用cevisord运行芹菜进入 生产环境 ,我不知道为什么但是有时候运行芹菜的一些过程会占用CPU的100%用量并保持这一点,直到我重新启动芹菜杀死现有过程 . 当这个发生的 Worker 没有得到更多的任务,他们没有被... -
2 votesanswersviews
芹菜没有在 生产环境 中运行
我正在尝试在 生产环境 中经营芹菜和芹菜 . 在我目前的django应用程序中,我能够使用命令“celery -A Gorgon worker”和“celery -A Gorgon beat -l debug --max-interval = 10”进行测试和运行 . 另外,我通过virtualenv运行它 . 另外,我使用redis作为任务经纪人 . 整个应用程序在gunicorn服务器上运行 ... -
1 votesanswersviews
Celery,Django和Scrapy:从django应用程序导入时出错
我正在使用 celery (和 django-celery )来允许用户通过django admin启动定期搜索 . 这是一个更大的项目的一部分,但我把问题归结为一个最小的例子 . 首先,celery / celerybeat正在运行daemonized . 如果我用我的django项目目录 celery -A evofrontend worker -B -l info 然后 I get no i... -
7 votesanswersviews
通过Django-celery调度数千个一次性(非重新安置)任务以实现近同步执行
一些上下文:我正在构建一个Django应用程序,允许用户预先保存操作,并安排他们希望执行该操作的未来的确切日期/时间 . 例如,安排一个帖子将在下周早上5:30以编程方式推送到Facebook墙上 . 我正在寻找一个可以处理一次性任务的一千个实例的任务调度系统,所有这些都设置为几乎同时执行(误差范围加上或减去一分钟) . 我正在考虑使用Django-celery / Rabbitmq,但我注意到C... -
0 votesanswersviews
Django芹菜 Worker 没有收到任务
每当我运行芹菜 Worker 时,我都会收到警告 ./manage.py celery worker -l info --concurrency=8 如果我被忽略这个警告,那么我的芹菜 Worker 没有收到芹菜打败任务 在googled之后我也改变了 Worker 的名字,但是这次我没有收到警告但是芹菜 Worker 仍然没有收到芹菜打败预定的任务 我检查了芹菜捶打日志,芹菜按时按时安排任务... -
1 votesanswersviews
芹菜没有从Django Admin周期性任务中获取任务
使用芹菜3.1.25与Django 1.10 我可以通过手动进入shell并手动启动任务来获得芹菜来运行任务 . 但是,当我从django / admin / PeriodicTasks设置任务(每分钟运行一次)时,芹菜不会接收这些任务 . 我正在使用花来检查状态,但我没有看到任何失败的任务 . 代理节点被称为 celery@USER-vm 而不是 default ,因此我不知道这是否会影响这一点... -
0 votesanswersviews
Django-celery-beat是连续调度间隔任务
我最近关注了这个教程:https://www.codingforentrepreneurs.com/blog/celery-redis-django/ 为了配置django-celery-beat . 如果我像这样启动节拍工作,一切正常: celery -A proj beat -l info 但是,如果我让节拍调度程序使用django DB,如下所示: celery -A proj beat ... -
8 votesanswersviews
如何诊断挂起的芹菜 Worker
我正在开始使用Celery进行Django项目 . 为了本地开发目的,我根据这些指令http://ask.github.com/celery/tutorials/otherqueues.html#django-database设置了djcelery和djkombu(数据库传输),但计划在 生产环境 服务器上使用rabbitmq . 我've found that it works but that... -
30 votesanswersviews
如何将周期性任务发送到Celery中的特定队列
默认情况下,Celery将所有任务发送到“celery”队列,但您可以通过添加额外参数来更改此行为: @task(queue='celery_periodic') def recalc_last_hour(): log.debug('sending new task') recalc_hour.delay(datetime(2013, 1, 1, 2)) # for example... -
0 votesanswersviews
Django和RabbitMQ设置
我在负载均衡器后面的多个VM上部署了一个django应用程序 . 在每个django . 我想为应用程序设置celery和RabbitMQ . 每个django应用程序都将运行一个芹菜工作者,一些VM应该在群集设置中运行RabbitMQ,如果芹菜工作者执行任务,其他人不应该执行相同的任务 . 这种设置芹菜和RabbitMQ的方法很好 . 任何人都可以指导我如何设置(配置,教程等)? -
1 votesanswersviews
如何将Celery任务注册到特定工作者?
我正在使用Python / Django开发Web应用程序,我有几个在芹菜中运行的任务 . 我必须一次运行一个任务A,所以我使用--concurrency = 1创建了worker,并使用以下命令将任务A路由到该worker . celery -A proj worker -Q A -c 1 -l INFO 当这个worker处理任务A并且其他任务被路由到默认队列时,一切正常 . 但是,当我使用... -
0 votesanswersviews
芹菜调度任务定期但不执行它们
我的django app有两个任务,其中一个是周期性任务 . 正常任务: AddScore 周期性任务: CalculateTopScore class CalculateTopScore(celery.Task): default_retry_delay = settings.DEFAULT_RETRY_DELAY max_retries = settings.DEFAULT_... -
1 votesanswersviews
导入Celery worker时导入错误
当我使用 celery worker 命令启动芹菜工作时,我收到以下错误 . 否则,Django项目似乎运行良好 . $ celery -A testproj worker -l info Traceback (most recent call last): File "/Users/devang/virtualenvs/testproj/bin/celery", line...