greyli
commented
5 years ago 你好，看了你的代码，配置和上下文错误是因为你注册任务的 celery 对象和加载配置和上下文的 celery 对象不是同一个。
你注册任务时是从 extensions.py 导入的 celery，这个 celery 对象什么也没做。而真正加载了配置，设置了上下文的 celery 对象是你在 __init__.py 文件的 make_celery() 函数返回的那个，但是因为被放到了工厂函数里，根本没法引用。
大概有这些改进建议：
- 两选一，建议删除所有和 Flask-Celery 扩展相关的代码，直接使用 Celery。
- 把
celery对象作为全局变量定义在 init.py 文件中。具体来说，保留make_celery()函数，但把第一行的celery定义移动到工厂函数上方。 - 在定义任务的脚本里，导入 __init__.py 里定义的
celery对象。 - （可选）单独创建一个脚本保存 Celery 的配置，下面的示例代码把 Celery 配置单独保存到 celeryconfig.py 里。这不是必需的，不过因为新版本建议用小写形式的配置，而 Flask 只支持大写的配置变量，最好还是分离开。
示例代码如下：
from flask import Flask
from celery import Celery
from celeryconfig import broker_url # 你可以从你的配置文件里读取那两个变量
celery = Celery(__name__, broker=broker_url) # 也可以直接把配置的值写到这里
def create_app(config_name=None):
# ...
app = Flask(__name__)
app.config.from_object(config[config_name])
register_celery(app)
# ...
return app
def register_celery(app):
celery.config_from_object('celeryconfig') # 这里可以沿用你的配置加载代码
class ContextTask(celery.Task):
def __call__(self, *args, **kwargs):
with app.app_context():
return self.run(*args, **kwargs)
celery.Task = ContextTask补充一下，在 Stack Overflow 看到另一种实现方式（link），可以为 Celery 也创建一个工厂函数：
#factory.py
from celery import Celery
from config import config
def create_celery_app(app=None):
app = app or create_app(config)
celery = Celery(__name__, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)
TaskBase = celery.Task
class ContextTask(TaskBase):
abstract = True
def __call__(self, *args, **kwargs):
with app.app_context():
return TaskBase.__call__(self, *args, **kwargs)
celery.Task = ContextTask
return celery在 tasks.py 调用工厂函数创建 celery 对象：
#tasks.py
from factory import create_celery_app
celery = create_celery_app()
@celery.task
def do_something():
pass
BobcatsII
打扰您了，上周末两天遇到celery的相关问题一直卡着过不去，google搜索和官方文档相关的都看了，大体上晓得在单个文件中该怎么写，但是在我写的网站（套用您的albumy的壳子，页面地址：https://github.com/BobcatsII/Opps.git ），不知道该把celery的配置放在哪里，官方文档和google查的例子都是放在同一个文件的app.py内或者是将extensions.py和init.py融合在一起的文件内，我的网站内的celery配置在如下文件中，方便您查看：[ init.py，extensions.py，settings.py，新增tasks.py，路由blueprint/deploy.py ]，导致我在用celery命令（celery -A opps.tasks.celery worker -l info）启动的时候，加载的celery连接rabbitmq总是默认连接 “[2018-12-24 15:17:12,299: INFO/MainProcess] Connected to amqp://guest:**@127.0.0.1:5672//”，不是我settings.py里面设定的连接，而且启动后我在页面点击"开始部署"的时候，celery进程提示我"程序上下文"有问题，虽然按照官方文档给的样例写了上去，我感觉我应该是对 extensions.py和init.py这两个文件的理解有问题，还请您抽空能指点一下我问题出在哪里，谢谢您！！