python—Celery異步分布式
阿新 • • 發佈:2017-12-21
pythonCelery異步分布式
Celery是一個python開發的異步分布式任務調度模塊
Celery本身並不提供消息服務,使用第三方服務,也就是borker來傳遞任務,目前支持rebbimq,redis, 數據庫等
使用redis連接url的格式為:
redis://:password@hostname:port/db_number
例如:
BROKER_URL = 'redis://localhost:6379/0'
1)huang.py
from celery import Celery
broker = "redis://192.168.2.230:6379/1"
backend = "redis://192.168.2.230:6379/2"
app = Celery("huang",broker=broker,backend=backend)
@app.task
def add(x,y):
return x+y
2)安裝celery:
pip install celery
pip install redis
啟動:celery -A huang worker -l info
3)celery.py #調用
from test import add
re = add.delay(10,20)
print(re.result)
print(re.ready)
print(re.get(timeout=1))
print(re.status)
python—Celery異步分布式