2.celery配置与基本使用

1.1安装celery

pip install celery==5.0.0

1.2 新建 celery/main.py 配置celery

import os
from celery import Celery
import sys

# 定义celery实例, 需要的参数, 1, 实例名, 2, 任务发布位置, 3, 结果保存位置
from utils.rl_sms import send_message

app=Celery(
    'mycelery',
    broker='redis://127.0.0.1:6379/14', # 任务存放的地方
    backend='redis://127.0.0.1:6379/15') # 结果存放的地方


# @app.task 指定将这个函数的执行交给celery异步执行
@app.task
def add(x, y):
    return x + y

2.测试celery

2.1 启动celery

'''1.启动celery''' 
#1.1 单进程启动
celery celery -A main worker -l INFO 
#1.2 celery管理 
celery multi start celery_test -A celery_test -l debug --autoscale=50,5 
# celery并发数：最多50个，最少5个
ps auxww|grep "celery worker"|grep -v grep|awk '{print $2}'|xargs kill -9 # 关闭所有celery进程