day6 celery配置與基本使用

2022-07-24 07:06:11 字數 776 閱讀 6117

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

celery/main.py

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