Celery，异步任务调度的专家！

一行玩python

于 2024-11-23 19:38:57 发布

阅读量338

点赞数 5

更多资料、源码请关注公众号「一行玩python」即可领取

本文链接：https://blog.csdn.net/qq_42554007/article/details/144002838

版权

嗨，Python小伙伴们！今天咱们来学超棒的Celery，它就像一个超级任务管家，能帮我们把耗时的任务放到后台异步处理，就像把繁琐的家务交给管家，我们可以继续做其他事情。无论是处理大量数据、发送邮件还是进行图片处理，Celery都能高效调度，开启异步任务之旅吧！

一、安装Celery

安装Celery不难哦，就像给Python装个得力助手。在命令行里输入：

pip install celery

小贴士：要是安装的时候遇到问题，比如网络不好或者提示缺少依赖，先检查网络，要是缺依赖库，像一些消息中间件的库（如果要用特定消息中间件的话），得先装上哦，不然Celery没法正常工作啦。

二、创建一个简单的Celery任务

咱们先创建一个简单的Celery任务，这就像给管家安排一个简单的家务活儿。

# 首先导入Celery模块
from celery import Celery

# 创建Celery实例，这里的'myapp'是应用名，可以自己修改
app = Celery('myapp', broker='redis://localhost:6379/0')

# 定义一个任务函数，这个函数就像管家要做的具体家务
@app.task
def add(x, y):
    return x + y

这里Celery类创建了Celery实例，broker参数指定消息中间件（这里用Redis），@app.task装饰器把普通函数变成Celery任务。小贴士：消息中间件的配置要正确哦，不然任务可能无法正常传递和执行呢。

三、调用Celery任务

有了任务，就得调用它，这就像告诉管家开始干活啦。

# 假设已经有上面定义的Celery应用实例app

# 异步调用add任务，就像吩咐管家去做加法这个家务，不用等结果马上返回
result = app.send_task('add', args=(3, 5))
print(result)

这里app.send_task函数异步调用任务，传入任务名和参数。小贴士：调用任务后可以先做其他事情，等需要结果的时候再获取哦。

四、获取任务结果

当我们需要任务结果的时候，可以获取它，这就像管家做完家务后汇报结果。

# 假设已经有上面调用任务得到的result对象

# 等待任务完成并获取结果，这就像耐心等待管家做完并听汇报
final_result = result.get()
print(final_result)

这里result.get方法会阻塞等待任务完成并返回结果。小贴士：如果任务还没完成就调用get方法，会一直等待哦，所以可以根据情况合理安排获取结果的时机。

五、在Django或Flask中使用Celery（以Flask为例）

Celery还能在Web框架里大显身手哦，比如在Flask中，这就像管家在Web商店里帮忙处理后台事务。

# 在Flask应用里使用Celery
from flask import Flask
from celery import Celery

app = Flask(__name__)
# 创建Celery实例并和Flask应用关联
celery = Celery(app.name, broker='redis://localhost:6379/0')
celery.conf.update(app.config)

# 定义一个在Flask里的Celery任务
@celery.task
def process_data(data):
    # 这里可以进行一些数据处理，比如对数据排序
    return sorted(data)

# 在Flask视图函数里调用Celery任务
@app.route('/process')
def process():
    data = [5, 2, 8, 1]
    # 异步调用任务
    task_result = process_data.delay(data)
    return "任务已提交，结果稍后查看"

这里Celery实例和Flask应用关联，process_data任务在Flask里定义并能被视图函数调用。小贴士：在Web框架里使用Celery要注意应用上下文等问题哦，不然可能会出错呢。