python celery 異步學習

1.運行redis

2.安裝celery：pip install celery[redis]

3.vim task.py

import time
from celery import Celery

broker = 'redis://localhost:6379/1'
backend = 'redis://localhost:6379/2' 
app = Celery("my_task",broker=broker,backend=backend) #my_task 是用來生成任務名的前綴  

@app.task 
def add(x,y): 
    print("enter call func....") 
    time.sleep(4) 
    return x + y

4.vim app.py

import time
from task import add

if __name__ == '__main__':
    print("start task....")
    result = add.delay(10,20)
    print(result)

5.啓動celery worker

celery worker -A task【任務文件名】 -l INFO

 

 6.運行app.py或者執行add函數

 

python下：

啓動worker：celery worker -A celery_app -l INFO
啓動定時任務：celery beat -A celery_app -l INFO

用一條命令同時啓動worker和定時任務：celery -B -A celery_app worker -l INFO

djangp下：

啓動worker：python manage.py celery worker -l INFO
啓動定時任務：python manage.py celery beat -l INFO

使用flower監控任務：pip install flower
啓動：python manage.py celery flower
認證啓動：python manage.py celery flower --basic_auth=chenjiaen:root123456.
打開頁面鏈接：http://115.159.118.25:5555

使用 supervisor 管理進程生成配置文件：echo_supervisord_conf > conf/supervisord.conf