草庐IT

celery_state

全部标签

python - Celery worker 不会为应用程序启动 ImportError

我正在尝试将celery与django一起使用,并以redis作为代理。我的应用程序名称之一是用户,其模型由其他应用程序导入。当我运行django服务器时,它启动时没有任何错误,并且一切正常。但是当我尝试使用命令“celery-Aprojectworker-lINFO”启动celeryworker时,出现以下错误:Traceback(mostrecentcalllast):File"/usr/local/bin/celery",line11,insys.exit(main())File"/usr/local/lib/python2.7/dist-packages/celery/__ma

django - 使用 Django 应用程序的主管对运行 celery worker 进行故障排除

我有一个Django应用程序,我的目标是通过celery通过redis运行任务。项目文件夹结构如下:/mhb11/myfolder/myproject├──myproject│├──celery.py#TheCeleryappfile│├──__init__.py#Theprojectmodulefile(modified)│├──settings.py#IncludingCelerysettings│├──urls.py│└──wsgi.py├──manage.py├──celerybeat-schedule└──myapp├──__init__.py├──models.py├──t

python - 向所有 worker 广播任务 : redis+celery

任务.pyfromceleryimportCeleryapp=Celery('tasks',broker='redis://localhost',backend='redis://localhost',include=['tasks'])app.conf.broker_url='redis://localhost:6379/0'#Optionalconfiguration,seetheapplicationuserguide.app.conf.update(result_expires=3600,)@app.taskdefadd(x,y):returnx+y主要.pyfromtasks

python - 自定义 Celery Task 类无法正常工作

我正在努力让Celery工作。一般来说,我是Python的新手,显然是Celery的新手,我正在尝试获得基本的示例工作。我想运行一个后台任务,只要它还活着,它就应该保持它的状态。因此,我尝试实现从客户端脚本调用时递增整数变量的基本示例。我正在使用raspbian图像开发RaspberryPi。这是我的工作任务代码:fromceleryimportTask,registry,Celeryimportcelerycelery=Celery('tasks',broker='redis://localhost:6379',backend='redis://localhost:6379')cla

django - Celery 与 Django 和 MongoDB (mongoengine)

1)我正在尝试使用Celery(以RabbitMQ作为代理)和Django构建一个应用程序-使用MongoDB(mongoengine)作为模型的数据库。因此,Web服务器收到的请求将转换为任务,并在Celery的帮助下排队等待工作人员执行。我遵循了以下教程:http://docs.celeryproject.org/en/master/django/first-steps-with-django.html#configuring-your-django-project-to-use-celery和https://mongoengine-odm.readthedocs.org/en/l

mongodb - 蒙哥错误: server instance in invalid state undefined after upgrading mongoose module

我将我的mongoosenpm模块从"mongoose":"~3.8.8"更新为"mongoose":"^4.1.12"。我按原样使用简单的MEAN项目documentedhere升级mongoose节点模块后出现以下错误:MongoError:serverinstanceininvalidstateundefinedatFunction.MongoError.create(SampleProject\node_modules\mongodb-core\lib\error.js:29:11)atServer.connect(SampleProject\node_modules\mong

mongodb - MongoReplicaSetClient 不会在 celery worker 中重新连接

我使用带有MongoDB2.4.4副本集的Celery3.0.15作为后端(pymongo版本2.5.1)。我还使用相同的副本集作为主应用程序数据存储:CELERY_CONFIG={'BROKER_URL':'mongodb://localhost:27017,localhost:27018,localhost:27019/','BROKER_TRANSPORT_OPTIONS':{'replicaSet':'test'}}...conn=MongoReplicaSetClient('localhost:27017,localhost:27018,localhost:27019',re

python - 如何在 Celery worker 中正确连接到 mongodb?

学习Celery,阅读CeleryBestPractices,并且有一个关于Celery数据库使用的非常简单的问题。DeniBertovic说:Youshouldn'tpassDatabaseobjects(forinstanceyourUsermodel)toabackgroundtaskbecausetheserializedobjectmightcontainstaledata.那么,如果我想在worker中连接数据库,正确的选择是什么:@app.taskdefadd(x,y,collection):client=MongoClient('mongodb://localhost:

django - Celery 任务似乎可以完成除写入数据库之外的所有操作

我将Django与MongoEngine、django-celery和用于celery的MongoDB后端一起使用。我正在排队一项任务。该任务涉及从GridFS(通过MongoEngineFileField)获取文件,对其进行操作并将其放回数据库中。任务按预期运行,没有排队。当我对它进行排队时,它会转换文件,但不会写入数据库。这是我的settings.py的相关部分。#TheseareapparentlydefaultsthatIshouldn'tneedBROKER_BACKEND='mongodb'BROKER_HOST="localhost"BROKER_PORT=27017BR

python - 为什么 MongoDB 在 Celery 连接上无法识别我的用户?

我在DotCloud托管上有一个带有MongoDB数据库的Python/Flaskwebapp。我想使用MongoDB服务作为Celery队列在Python服务上设置Celery。Celery启动并找到我的celeryconfig.py文件,其中包含:BROKER_BACKEND="mongodb"BROKER_HOST="data.myapp.dotcloud.com"BROKER_PORT=8567BROKER_USER='myuser'BROKER_PASSWORD='mypass'CELERY_IMPORTS=('myapp.worker',)CELERY_IGNORE_RES