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

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

celery配置與基本使用

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