day6 celery配置與基本使用

pip install 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

'''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配置與基本使用

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,結果...