将参数传递给芹菜任务的Flask路由

from flask import Flask

app = Flask(__name__)

@app.route('/task/<task_id>')
def task_handler(task_id):
    # 在这里处理任务
    return 'Task ID: {}'.format(task_id)

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

from flask import Flask
from celery import Celery

app = Flask(__name__)
celery = Celery(app.name, broker='redis://localhost:6379/0')

@celery.task
def celery_task(task_id):
    # 在这里处理芹菜任务
    return 'Task ID: {}'.format(task_id)

@app.route('/task/<task_id>')
def task_handler(task_id):
    # 调用芹菜任务
    celery_task.delay(task_id)
    return 'Task ID: {} has been scheduled'.format(task_id)

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