一、簡(jiǎn)介
celery是異步任務(wù)隊(duì)列框架,支持實(shí)時(shí)處理消息任務(wù)，和定時(shí)處理消息任務(wù).
架構(gòu)圖:

創(chuàng)新互聯(lián)成都企業(yè)網(wǎng)站建設(shè)服務(wù)，提供成都網(wǎng)站設(shè)計(jì)、網(wǎng)站建設(shè)網(wǎng)站開(kāi)發(fā),網(wǎng)站定制,建網(wǎng)站,網(wǎng)站搭建,網(wǎng)站設(shè)計(jì),自適應(yīng)網(wǎng)站建設(shè),網(wǎng)頁(yè)設(shè)計(jì)師打造企業(yè)風(fēng)格網(wǎng)站,提供周到的售前咨詢和貼心的售后服務(wù)。歡迎咨詢做網(wǎng)站需要多少錢:13518219792

組件說(shuō)明:
producer: 調(diào)用celery api，函數(shù)，裝飾器，生成task，放入消息隊(duì)列的都是生產(chǎn)者
celery beat: 任務(wù)調(diào)度器,beat進(jìn)程讀取配置文件，周期性的將配置文件中需要執(zhí)行的任務(wù)放入隊(duì)列
broker: 消息代理中間件,task任務(wù)存入隊(duì)列，供worker取出執(zhí)行
worker: 執(zhí)行任務(wù)的消費(fèi)者,可以開(kāi)啟多個(gè)線程執(zhí)行
backend: 任務(wù)處理完后保存狀態(tài)信息和結(jié)果，以供查詢

二、簡(jiǎn)單使用
項(xiàng)目結(jié)構(gòu)

app_test.py實(shí)例化celery
from celery import Celery
app = Celery('celerydemo',include=['celerydemo.tasks'])
app.config_from_object('celerydemo.celeryconfig')

if name== 'main':
app.start()

創(chuàng)建任務(wù)tasks.py
import time
from celerydemo.app_test import app

@app.task
def add(x,y):
time.sleep(1)
return x+y

添加配置文件celeryconfig.py
BROKER_URL = 'redis://:123456@127.0.0.1:6379/0'

CELERY_RESULT_BACKEND = 'redis://:123456@127.0.0.1:6379/0'
CELERY_TASK_SERIALIZER = 'msgpack'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_RESULT_EXPIRES = 60 60 24
CELERY_ACCEPT_CONTENT = ['json', 'msgpack']

創(chuàng)建worker消費(fèi)者線程
celery -A celerydemo.app_test worker -l info

調(diào)用任務(wù)exec.py 放入隊(duì)列,并輸出結(jié)果
from celerydemo.tasks import add
import time
t1 = time.time()

#調(diào)用delay將任務(wù)插入broker隊(duì)列
r1 = add.delay(1,2)
r2 = add.delay(2,2)
r3 = add.delay(3,2)
r4 = add.delay(4,2)
r5 = add.delay(5,2)

r_list = [r1,r2,r3,r4,r5]

for r in r_list:
while not r.ready():
pass
print(r.result)

t2 = time.time()

print('共耗時(shí): %s' % str(t2-t1))

網(wǎng)站標(biāo)題：celery簡(jiǎn)單使用
地址分享：http://www.chinadenli.net/article2/ishgic.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供微信小程序、軟件開(kāi)發(fā)、靜態(tài)網(wǎng)站、全網(wǎng)營(yíng)銷推廣、搜索引擎優(yōu)化、網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)