1.celery配置與基本使用

1.1安裝相關軟體包

pip3 install Django==2.0.4
pip3 install celery==4.3.0
pip3 install redis==3.2.1
pip3 install  django-celery==3.1.17
pip3 install ipython==7.6.1 

find ./ -type f | xargs sed -i 's/\r$//g'  # 批量將當前資料夾下所有檔案裝換成unix格式

1.2celery管理/命令/測試

#1.1 單程序啟動celery
celery -A main worker -l INFO  
celery multi start w1 w2 -A celery_pro -l info #一次性啟動w1，w2兩個worker
celry -A celery_pro status # 檢視當前有那些worker在工作
celery multi stop w1 w2 -A celery_pro              #停止w1,w2兩個worker

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程序

 

1.3 新建celery/main.py配置celery

# celery_task/main.py
import os
from celery import Celery

# 定義celery例項, 需要的引數, 1, 例項名, 2, 任務釋出位置, 3, 結果儲存位置
app = Celery('mycelery',
             broker='redis://127.0.0.1:6379/14',  # 任務存放的地方 
             backend='redis://127.0.0.1:6379/15')  # 結果存放的地方


@app.task
def add(x, y):
    return x + y
 

如果對您有用，就動動發財的小手，請點個贊再走吧~