芹菜配烧瓶和UWSGI

Question

我有一个简单的应用瓶，上面有一个简单的芹菜任务：

from flask import Flask
from celery import Celery

app = Flask(__name__)
app.config['CELERY_BROKER_URL'] = 'redis://localhost:6379'
app.config['CELERY_RESULT_BACKEND'] = 'redis://localhost:6379'
celery = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)
@celery.task
def add(x, y):
return x + y

@app.route('/', methods=['GET'])
def test_func():
res = add.delay(4,5)
while not res.ready():
pass
data = res.get()
return str(data)
if __name__ == '__main__':
app.run(host='0.0.0.0',debug=True)

当我尝试将您的示例与 uwsgi 一起使用时，但我遇到了与您几乎相同的错误。 首先，我简单地用python运行它：

python app.py

以及使用以下命令的代理：

celery -A app.celery worker -l info

一切都很完美。现在我尝试使用 uwsgi 启动烧瓶应用程序。

[uwsgi]
mount = /=/home/admin/flask-celery/app.py
callable = app
virtualenv = /home/admin/flask-celery/.venv
socket = :3031
master = true 
processes = 2
threads = 4
http = :9000

但是当我继续我的路线时，我遇到了以下错误：

celery.exceptions.NotRegistered: 'uwsgi_file__home_admin_flask-celery_app.add'

Answer 1

请看一下这个：https：//uwsgi-docs.readthedocs.io/en/latest/AttachingDaemons.html

尽管以下配置不完全匹配您的环境，但我希望这会有所帮助。

[uwsgi]
base = /home/project
chdir = %(base)
module = app
pythonpath = %(base)
virtualenv = %(base)/venv
wsgi-file = %(base)/app.py
master = true
smart-attach-daemon = %(base)/tmp/celery.pid %(virtualenv)/bin/celery -A %(module).celery  worker --pidfile=%(base)/tmp/celery.pid
socket = %(base)/socket.sock
chmod-socket = 777
processes = 4
threads = 4
logto = %(base)/log/%n.log
stats = 127.0.0.1:9191

Answer 2

尝试显式指定任务名称，例如：

@celery.task(name='app.celery.add')
def add(x, y):
return x + y

为确保更改生效，请在进行更改后重新启动 celery worker 并使用find . -name '*.pyc' -delete清理所有*.pyc文件