jjzjj

djcelery

全部标签

python - Django/djcelery 1.8.2 AppRegistryNotReady : Translation infrastructure cannot be initialized

我收到以下错误:File"/Library/Python/2.7/site-packages/Django-1.8.2-py2.7.egg/django/utils/translation/trans_real.py",line164,in_add_installed_apps_translations"Thetranslationinfrastructurecannotbeinitializedbeforethe"django.core.exceptions.AppRegistryNotReady:Thetranslationinfrastructurecannotbeinitial

django - Djcelery 强制使用 'database' 后端,如何正确绕过它?

在我的Django项目中,我根本不使用SQL数据库,我的主要数据存储是MongoDB,通过mongoengine.我想将Celery设置为与Redis一起作为代理和后端。我安装了django-celery-with-redis,安装了Redis(在本地和生产环境中),并尝试在我的settings.py中使用以下内容:BROKER_URL='redis://localhost:6379/0'CELERY_RESULT_BACKEND=BROKER_URLimportdjcelerydjcelery.setup_loader()但是当我运行celery进程并且它收到一个要处理的任务时,当返

django - Djcelery 强制使用 'database' 后端,如何正确绕过它?

在我的Django项目中,我根本不使用SQL数据库,我的主要数据存储是MongoDB,通过mongoengine.我想将Celery设置为与Redis一起作为代理和后端。我安装了django-celery-with-redis,安装了Redis(在本地和生产环境中),并尝试在我的settings.py中使用以下内容:BROKER_URL='redis://localhost:6379/0'CELERY_RESULT_BACKEND=BROKER_URLimportdjcelerydjcelery.setup_loader()但是当我运行celery进程并且它收到一个要处理的任务时,当返

python - 使用 current_app.send_task 时,Celery 任务路由不起作用

我在使用current_app.send_task时遇到Celery队列路由问题我有两个worker(每个队列一个)pythonmanage.pyceleryworker-E-Qpriority--concurrency=8--loglevel=DEBUGpythonmanage.pyceleryworker-Qlow--concurrency=8-E-B--loglevel=DEBUG我在celeryconfig.py文件中定义了两个队列:#-*-coding:utf-8-*-from__future__importunicode_literalsfromdjango.core.ex

python - 使用 current_app.send_task 时,Celery 任务路由不起作用

我在使用current_app.send_task时遇到Celery队列路由问题我有两个worker(每个队列一个)pythonmanage.pyceleryworker-E-Qpriority--concurrency=8--loglevel=DEBUGpythonmanage.pyceleryworker-Qlow--concurrency=8-E-B--loglevel=DEBUG我在celeryconfig.py文件中定义了两个队列:#-*-coding:utf-8-*-from__future__importunicode_literalsfromdjango.core.ex

python - 在 celery 中如何获得队列中的任务位置?

我使用Celery和Redis作为代理,我可以看到队列实际上是一个以序列化任务作为项目的Redis列表。我的问题是,如果调用.delay()后我有一个AsyncResult对象,有没有办法确定项目在队列中的位置?更新:我终于能够通过以下方式获得职位:fromcelery.task.controlimportinspecti=inspect()i.reserved()但它有点慢,因为它需要与所有worker沟通。 最佳答案 您提到的inspect.reserved()/scheduled()可能有效,但不是总是准确的,因为它只考虑任务

python - 在 celery 中如何获得队列中的任务位置?

我使用Celery和Redis作为代理,我可以看到队列实际上是一个以序列化任务作为项目的Redis列表。我的问题是,如果调用.delay()后我有一个AsyncResult对象,有没有办法确定项目在队列中的位置?更新:我终于能够通过以下方式获得职位:fromcelery.task.controlimportinspecti=inspect()i.reserved()但它有点慢,因为它需要与所有worker沟通。 最佳答案 您提到的inspect.reserved()/scheduled()可能有效,但不是总是准确的,因为它只考虑任务

python - 特定于队列的 Celery 事件

我有两个Django项目,每个项目都有一个Celery应用程序:-fooproj.celery_app-barproj.celery_app每个应用都在运行自己的Celeryworker:celeryworker-Afooproj.celery_app-linfo-E-Qfoo_queueceleryworker-Abarproj.celery_app-linfo-E-Qbar_queue以下是我配置Celery应用程序的方式:importosfromceleryimportCeleryfromdjango.confimportsettings#setthedefaultDjangos

python - 特定于队列的 Celery 事件

我有两个Django项目,每个项目都有一个Celery应用程序:-fooproj.celery_app-barproj.celery_app每个应用都在运行自己的Celeryworker:celeryworker-Afooproj.celery_app-linfo-E-Qfoo_queueceleryworker-Abarproj.celery_app-linfo-E-Qbar_queue以下是我配置Celery应用程序的方式:importosfromceleryimportCeleryfromdjango.confimportsettings#setthedefaultDjangos

python - 通过 pdb 调试 djcelery 的 celeryd

有人试过用pdb调试celerydworker吗?每当遇到断点时(通过pdb或pdb.set_trace()运行celeryd),我都会遇到以下错误:Errorwhilehandlingactionevent.Traceback(mostrecentcalllast):File"/home/jeeyo/workspace3/uwcr/subscriptions/tasks.py",line79,inprocess_action_eventfunc(action_event)File"/home/jeeyo/workspace3/uwcr/subscriptions/tasks.py",
12