Celery配置與基本使用

1.1安裝celery

pip install celery @

1.2新建celery/main.py配置celery

#

celery_task/main.py
import
osfrom celery import
celery
#定義celery例項, 需要的引數, 1, 例項名, 2, 任務發布位置, 3, 結果儲存位置
mycelery',
broker='
redis:
', #
任務存放的地方 
backend='
redis:
') #
結果存放的地方
defadd(x, y):
return x + y

2.測試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 '
'|xargs kill -9 #
關閉所有celery程序

celery配置與基本使用

定義celery例項,需要的引數,1,例項名,2,任務發布位置,3,結果儲存位置 mycelery broker redis 任務存放的地方 backend redis 結果存放的地方 defadd x,y return x y 1.啟動celery 1.1 單程序啟動celery celery a...

celery配置與基本使用

定義celery例項,需要的引數,1,例項名,2,任務發布位置,3,結果儲存位置 mycelery broker redis 任務存放的地方 backend redis 結果存放的地方 defadd x,y return x y 測試時一般使用併發數高的 1.啟動celery 1.1 單程序啟動ce...

celery配置與基本使用

pip install celery celery task main.py import os from celery import celery 定義celery例項,需要的引數,1,例項名,2,任務發布位置,3,結果儲存位置 broker redis 任務存放的地方 backend redis...