celery配置與基本使用

1.1 安裝celery 

pip install celery  https://github.com/celery/celery/tarball/master

　　

1.2 新建celery_text/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

　　

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

　2.2  另一終端 測試運行  celery_text/python 

　　　　　　import  main

　　　　　　main.add(1,2)  #

　　　　　　main.add.delay      

　　　　　　t=main.add.delay(1,2)      delay 調用 

　　　　　　t.get()