获取任务时使用芹菜工人掉落的Flask create_app

from flask import Flask
from celery import Celery

def make_celery(app):
    celery = Celery(
        app.import_name,
        backend=app.config['CELERY_RESULT_BACKEND'],
        broker=app.config['CELERY_BROKER_URL']
    )
    celery.conf.update(app.config)
    return celery

def create_app():
    app = Flask(__name__)
    
    # 配置 Celery
    app.config.update(
        CELERY_BROKER_URL='redis://localhost:6379/0',
        CELERY_RESULT_BACKEND='redis://localhost:6379/0'
    )
    
    celery = make_celery(app)
    
    @app.route('/')
    def index():
        return 'Hello, World!'
    
    # 定义一个 Celery 任务
    @celery.task()
    def add_together(a, b):
        return a + b
    
    return app

if __name__ == '__main__':
    app = create_app()
    app.run()