首页 文章
  • 1 votes
     answers
     views

    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 votes
     answers
     views

    芹菜 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 votes
     answers
     views

    (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 votes
     answers
     views

    Django和Celery的例子:周期性任务

    我一直在与Django / Celery文档争论一段时间,需要一些帮助 . 我希望能够使用django-celery运行Periodic Tasks . 我已经在互联网(和文档)周围看到了几种不同的格式和模式,以了解如何使用Celery实现这一目标... 有人可以帮助创建,注册和执行django-celery定期任务的基本功能示例吗?特别是,我想知道是否应该编写一个扩展PeriodicTask类并...
  • 2 votes
     answers
     views

    尝试运行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 votes
     answers
     views

    芹菜和芹菜之间的混乱

    我已经在我的django应用程序中成功安装了芹菜和django芹菜 . 我已经学习了很多教程,以便了解它 . 有些人像芹菜一样开始工作: python manage.py celery worker --loglevel=info 其他人用芹菜 d 开始: python manage.py celeryd –-verbosity=2 –loglevel=DEBUG 我有2个问题请: 我应该...
  • 1 votes
     answers
     views

    在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 votes
     answers
     views

    Django-celery和RabbitMQ没有执行任务

    我们有一个 Django 1.3 应用程序 django-celery 2.5.5 已经在 生产环境 中运行了一个月,但突然之一芹菜任务现在无法执行 . RabbitMQ代理和Celery工作程序在单独的机器上运行,celeryconfig.py配置为使用该特定RabbitMQ实例作为后端 . 在应用程序服务器上,我尝试通过 python manage.py shell 手动触发芹菜任务 . 实际...
  • 1 votes
     answers
     views

    使用Celery将消息发布到RabbitMQ中的Exchange

    我写了一个Django-Project,它通过 my_task.delay() 提示不同的任务异步 . 问题是随着项目变得越来越大,正确地路由任务真的很困难 - 我开始编写的任务只是为了组合不同的任务,这使得代码在一段时间后变得混乱 . 当我阅读一些RabbitMQ文档时,我遇到了一个解决方案,它可以更好地构建我的项目,依赖于Exchange . 交换可以将消息发布到Cosumer可以使用它的多个...
  • 1 votes
     answers
     views

    有没有办法在django-celery中验证经纪人的SSL证书?

    我正在使用django-celery通过SSL连接到RabbitMQ代理(使用BROKER_USE_SSL设置) . 有办法: Build 连接时验证代理的证书 . 配置客户端证书给我们以 Build 连接 . RabbitMQ方面正常工作,但我不知道如何为此配置Celery,我也没有在Celery的文档中找到任何内容 . 设置CELERY_SECURITY_KEY,CELERY_SE...
  • 4 votes
     answers
     views

    Celery:使用Redis作为result_backend,使用RabbitMQ作为消息代理

    我是Celery,Redis和RabbitMQ的新手 . 目前,我正在使用RabbitMQ作为消息代理,并且在配置中设置了nothings . (使用Django,MySQL) 我想知道是否可以在后端使用Redis作为结果存储,同时,RabbitMQ作为消息代理 . 我知道的事情只是添加一些设置, CELERY_RESULT_BACKEND = "redis"
  • 13 votes
     answers
     views

    Celery - RabbitMQ中的消息可以同时由两个或更多 Worker 消费吗?

    也许我在愚蠢地提出这个问题,但在进一步开展工作之前,我需要围绕基本概念 . 我正在处理几千个RSS源,使用多个Celery工作节点和RabbitMQ节点作为代理 . 每个订阅源的URL都作为消息写入队列中 . 工作人员只是从队列中读取URL并开始处理它 . I have to ensure that a single RSS feed does not get processed by two...
  • 2 votes
     answers
     views

    使用Celery以不同的优先级运行相同的任务

    所以我有一个非常有趣的场景,我希望以不同的优先级运行相同的Celery任务,具体取决于它的调用位置 - 例如,我想为优先级高的用户运行任务,优先级高于非高级用户 . 使用文档,我能够设置多个队列,并且能够通过将所有.delay调用更改为.apply_async调用并传入指定优先级队列的其他routing_key来使其工作 . 问题是必须在很多不同的地方做到这一点 . 有没有更好的方法来处理这个?我...
  • 1 votes
     answers
     views

    如何在ubuntu服务器上守护django芹菜周期性任务?

    在localhost上,我使用这些语句来执行任务和工作程序 . 运行任务:python manage.py celery beat Run worker:python manage.py celery worker --lvelvel = info我使用了otp,rabbitmq server和django-celery . 它工作正常 . 我在ubuntu服务器上上传了这个项目 . 我想要守护这...
  • 2 votes
     answers
     views

    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 votes
     answers
     views

    django-celery作为一个守护进程:不工作

    我有一个用django,芹菜和rabbitmq写的网站项目 . 单击按钮时会调用“.delay”任务(任务创建新文件夹) . 当我使用manage.py运行芹菜时,芹菜的一切正常(调用.delay任务,并创建一个新文件夹): python manage.py celeryd 但是,当我将celery作为守护程序运行时,即使没有错误,也没有执行任务(没有创建文件夹) . 我有点跟随教程:http:/...
  • 3 votes
     answers
     views

    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 votes
     answers
     views

    django-celery进程达到100%且任务未执行

    我在Ubuntu 12.04服务器上使用最新版本的django-celery和RabbitMQ Worker . 我在一个月前开始遇到芹菜任务的问题,我无法弄清楚问题是什么 . 我用cevisord运行芹菜进入 生产环境 ,我不知道为什么但是有时候运行芹菜的一些过程会占用CPU的100%用量并保持这一点,直到我重新启动芹菜杀死现有过程 . 当这个发生的 Worker 没有得到更多的任务,他们没有被...
  • 2 votes
     answers
     views

    芹菜没有在 生产环境 中运行

    我正在尝试在 生产环境 中经营芹菜和芹菜 . 在我目前的django应用程序中,我能够使用命令“celery -A Gorgon worker”和“celery -A Gorgon beat -l debug --max-interval = 10”进行测试和运行 . 另外,我通过virtualenv运行它 . 另外,我使用redis作为任务经纪人 . 整个应用程序在gunicorn服务器上运行 ...
  • 1 votes
     answers
     views

    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 votes
     answers
     views

    通过Django-celery调度数千个一次性(非重新安置)任务以实现近同步执行

    一些上下文:我正在构建一个Django应用程序,允许用户预先保存操作,并安排他们希望执行该操作的未来的确切日期/时间 . 例如,安排一个帖子将在下周早上5:30以编程方式推送到Facebook墙上 . 我正在寻找一个可以处理一次性任务的一千个实例的任务调度系统,所有这些都设置为几乎同时执行(误差范围加上或减去一分钟) . 我正在考虑使用Django-celery / Rabbitmq,但我注意到C...
  • 0 votes
     answers
     views

    Django芹菜 Worker 没有收到任务

    每当我运行芹菜 Worker 时,我都会收到警告 ./manage.py celery worker -l info --concurrency=8 如果我被忽略这个警告,那么我的芹菜 Worker 没有收到芹菜打败任务 在googled之后我也改变了 Worker 的名字,但是这次我没有收到警告但是芹菜 Worker 仍然没有收到芹菜打败预定的任务 我检查了芹菜捶打日志,芹菜按时按时安排任务...
  • 1 votes
     answers
     views

    芹菜没有从Django Admin周期性任务中获取任务

    使用芹菜3.1.25与Django 1.10 我可以通过手动进入shell并手动启动任务来获得芹菜来运行任务 . 但是,当我从django / admin / PeriodicTasks设置任务(每分钟运行一次)时,芹菜不会接收这些任务 . 我正在使用花来检查状态,但我没有看到任何失败的任务 . 代理节点被称为 celery@USER-vm 而不是 default ,因此我不知道这是否会影响这一点...
  • 0 votes
     answers
     views

    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 votes
     answers
     views

    如何诊断挂起的芹菜 Worker

    我正在开始使用Celery进行Django项目 . 为了本地开发目的,我根据这些指令http://ask.github.com/celery/tutorials/otherqueues.html#django-database设置了djcelery和djkombu(数据库传输),但计划在 生产环境 服务器上使用rabbitmq . 我've found that it works but that...
  • 30 votes
     answers
     views

    如何将周期性任务发送到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 votes
     answers
     views

    Django和RabbitMQ设置

    我在负载均衡器后面的多个VM上部署了一个django应用程序 . 在每个django . 我想为应用程序设置celery和RabbitMQ . 每个django应用程序都将运行一个芹菜工作者,一些VM应该在群集设置中运行RabbitMQ,如果芹菜工作者执行任务,其他人不应该执行相同的任务 . 这种设置芹菜和RabbitMQ的方法很好 . 任何人都可以指导我如何设置(配置,教程等)?
  • 1 votes
     answers
     views

    如何将Celery任务注册到特定工作者?

    我正在使用Python / Django开发Web应用程序,我有几个在芹菜中运行的任务 . 我必须一次运行一个任务A,所以我使用--concurrency = 1创建了worker,并使用以下命令将任务A路由到该worker . celery -A proj worker -Q A -c 1 -l INFO 当这个worker处理任务A并且其他任务被路由到默认队列时,一切正常 . 但是,当我使用...
  • 0 votes
     answers
     views

    芹菜调度任务定期但不执行它们

    我的django app有两个任务,其中一个是周期性任务 . 正常任务: AddScore 周期性任务: CalculateTopScore class CalculateTopScore(celery.Task): default_retry_delay = settings.DEFAULT_RETRY_DELAY max_retries = settings.DEFAULT_...
  • 1 votes
     answers
     views

    导入Celery worker时导入错误

    当我使用 celery worker 命令启动芹菜工作时,我收到以下错误 . 否则,Django项目似乎运行良好 . $ celery -A testproj worker -l info Traceback (most recent call last): File "/Users/devang/virtualenvs/testproj/bin/celery", line...

热门问题