celery配置與基本使用

pip install celery @ 

# celery_task/main.py

import os
from celery import celery
# 定義celery例項, 需要的引數, 1, 例項名, 2, 任務發布位置, 3, 結果儲存位置
broker='redis:', # 任務存放的地方 
backend='redis:') # 結果存放的地方
def add(x, y):
return x + y

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