在flask应用中使用celery任务队列,celery队列无法正常启动

Question

最近在写一个flask应用,想使用celery做任务队列,就去flask官网上找了样例程序,然后复制到本机上执行了一下,结果celery没有正常启动.只有一个源文件test.py,rabbitmq已配置并正常启动.代码如下:fromflaskimportFlaskfromceleryimportCelerydefmake_celery(app):celery=Celery(app.import_name,broker=app.config['CELERY_BROKER_URL'],backend=app.config['CELERY_RESULT_BACKEND'])celery.conf.update(app.config)TaskBase=celery.TaskclassContextTask(TaskBase):abstract=Truedef__call__(self,*args,**kwargs):withapp.app_context():returnTaskBase.__call__(self,*args,**kwargs)celery.Task=ContextTaskreturnceleryapp=Flask(__name__)app.config.update(CELERY_BROKER_URL='amqp://guest@localhost//',CELERY_RESULT_BACKEND='amqp://guest@localhost//')celery=make_celery(app)@celery.task()defadd_together(a,b):returna+bresult=add_together.delay(23,42)result.wait()差不多就是样例代码直接拷贝下来用了.然后我在当前目录下执行celery-Atestworker--loglevel=info和celery-Atest.celeryworker--loglevel=info之后阻塞,同时没有任何提示.我另外打开一个终端,在这个目录下执行pythontest.py之后发生阻塞.用pdb调试发现阻塞在最后一行result.wait().请问我的配置过程出现什么问题了?

Answer 1

最近刚好也在看flask和celery，不过用的是redis。先启动redis然后启动celeryceleryworker-Atest.celery--loglevel=info再启动flask。
你问题里没有描述实际报错，也不好回答你了。可以参考下链接描述