Celery怎么创建

这篇文章主要介绍“Celery怎么创建”，在日常操作中，相信很多人在Celery怎么创建问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Celery怎么创建”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

企业建站必须是能够以充分展现企业形象为主要目的，是企业文化与产品对外扩展宣传的重要窗口，一个合格的网站不仅仅能为公司带来巨大的互联网上的收集和信息发布平台，成都创新互联面向各种领域：成都塔吊租赁等成都网站设计、网络营销推广解决方案、网站设计等建站排名服务。

Celery 是什么？

Celery（中文是芹菜的意思）是Python语言实现的分布式队列服务，除了支持即时任务，还支持定时任务，Celery 有5个核心角色。

Task

任务(Task)就是你要做的事情，例如一个注册流程里面有很多任务，给用户发验证邮件就是一个任务，这种耗时的任务就可以交给Celery去处理，还有一种任务是定时任务，比如每天定时统计网站的注册人数，这个也可以交给Celery周期性的处理。

Broker

Broker 的中文意思是经纪人，指为市场上买卖双方提供中介服务的人。在Celery中这个角色相当于数据结构中的队列，介于生产者和消费者之间经纪人。例如一个Web系统中，生产者是主程序，它生产任务，将任务发送给 Broker，消费者是 Worker，是专门用于执行任务的后台服务。Celery本身不提供队列服务，一般用redis或者RabbitMQ来实现队列服务。

Worker

Worker 就是那个一直在后台执行任务的人，也成为任务的消费者，它会实时地监控队列中有没有任务，如果有就立即取出来执行。

Beat

Beat 是一个定时任务调度器，它会根据配置定时将任务发送给 Broker，等待 Worker 来消费。

Backend

Backend 用于保存任务的执行结果，每个任务都有返回值，比如发送邮件的服务会告诉我们有没有发送成功，这个结果就是存在Backend中，当然我们并不总是要关心任务的执行结果。

记住这5个角色后面理解Celery就轻松了。

快速入门

接触任何新东西，没有什么比实际动手学得更快了。假设我们选择Redis作为broker，你需要安装redis并且已经启动了redis服务（这个步骤请自行借用搜索引擎解决）

pip install -U "celery[redis]"

1、创建Celery实例

# tasks.py
from celery import Celery

app = Celery('tasks', broker='redis://localhost:6379/0')

2、创建任务

假设这个发送邮件的任务需要5秒钟才能执行完

# tasks.py
@app.task
def send_mail(email):
   print("send mail to ", email)
   import time
   time.sleep(5)
   return "success"

在没有Celery的情况下，程序顺序执行，每个步骤都需要等上一步执行完成。

1. 插入记录到数据库
2. 发邮件
3. 注册成功

我们可以把2放在一个任务中交给celery去执行，这样我们就不需要等待发邮件完成，你只需要安排celery去处理帮我去完成就好了。代码就变成了

1. 插入记录到数据库
2. celery 帮我去发邮件
3. 注册成功

第二步是非常快的，它只需要把任务放进队列里面去，并不会等任务真正执行完。这跟生活是完全贴切的，例如我们很多事情都不是自己亲历其为去做，而是将一个不太重要或即时性没那么高的事情转交给别人处理。

3、启动Worker

启动Worker，监听 Broker 中是否有任务，命令：celery worker，你可能需要指定参数

celery -A tasks worker --loglevel=info

-A： 指定 celery 实例所在哪个模块中，例子中，celery实例在tasks.py文件中，启动成功后，能看到信息

函数用app.task 装饰器修饰之后，就会成为Celery中的一个Task。

4、调用任务

在主程序中调用任务，掉任务发送给 Broker， 而不是真正执行该任务

# user.py
from tasks import send_mail

def register():
   import time
   start = time.time()
   print("1. 插入记录到数据库")
   print("2. celery 帮我发邮件")
   send_mail.delay("xx@gmail.com")
   print("3. 告诉用户注册成功")
   print("耗时：%s 秒 " % (time.time() - start))

if __name__ == '__main__':
   register()

在主程序中，调用函数的.delay方法

目录结构：

── celery_test
   ├── tasks.py
   └── user.py

运行 python user.py， 启动应用程序

1. 插入记录到数据库
2. celery 帮我发邮件
3. 告诉用户注册成功
耗时：0.22688984870910645 秒

程序花了不到0.23秒就执行完成，如果按照正常的同步逻辑去执行，至少需要5秒钟，因为发邮件的任务就花了5秒。

在worker服务窗口看日志信息

注意：

1、celery worker 启动时，如果是root用户，需要设置环境变量：

$ export C_FORCE_ROOT='true'

2、 Celery4.x 开始不再支持Windows平台，如果需要在Windows开发，请使用3.x的版本。

3、使用 RabbitMQ 或 Redis 作为 Broker，生产环境永远不要使用关系数据库

4、不要使用复杂对象作为任务函数的参数

# Good
@app.task
def my_task(user_id):
   user = User.objects.get(id=user_id)
   print(user.name)
   # ...

# Bad
@app.task
def my_task(user):
   print(user.name)
   # ...

到此，关于“Celery怎么创建”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注创新互联网站，小编会继续努力为大家带来更多实用的文章！