Celery+django+redis異步執(zhí)行任務的實現(xiàn)示例

更新時間：2025年04月23日 09:38:53 作者：皓陽當空

本文主要介紹了Celery+django+redis異步執(zhí)行任務的實現(xiàn)示例,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧

1.安裝redis

二進制文件是編譯完成后在src目錄下，通過下面的命令啟動Redis服務：

$ src/redis-server

你可以使用內(nèi)置的客戶端命令redis-cli進行使用：

$ src/redis-cli
redis> set foo bar
OK
redis> get foo
“bar”

下載，解壓，編譯:

# wget http://download.redis.io/releases/redis-3.2.6.tar.gz
# tar xzf redis-3.2.6.tar.gz
# cd redis-3.2.6
# make
# src/redis-server   # 啟動redis服務，看清楚，這是在你的redis-3.2.6目錄下執(zhí)行的
# src/redis-cli   # 啟動客戶端

2.安裝celery,redis

# pip install celery
# pip install redis

3.創(chuàng)建一個task

在django app目錄中創(chuàng)建tasks.py:

import time
from celery import task

@task()
def add(x, y):
    return x + y

@task
def sendmail(mail):
    print "++++++++++++++++++++++++++++++++++++"
    print('sending mail to %s...' % mail['to'])
    time.sleep(2.0)
    print('mail sent.')
    print "------------------------------------"
    return mail['to']

4.開啟worker

# celery -A tasks worker --loglevel=info

注意：上面命令中的tasks是你創(chuàng)建的task所在的python 文件名稱。如果你創(chuàng)建的這個tasks.py文件在app文件夾內(nèi)，那么你要這么執(zhí)行:

# celery -A app.tasks worker --loglevel=info

注意：每次更改tasks.py文件中的代碼后，都要重新執(zhí)行此命令！

5.試一下

>>> from app.tasks import *
>>> sendmail.delay(dict(to='asd@as.com'))
<AsyncResult: 694b6fa8-a123-4c22-9ba2-b77d7cbb066f>
>>> add.delay(2, 15)
<AsyncResult: 42d34419-4a34-49ab-9627-45428eaaeb38>
>>> a=add.delay(1,1)
>>> a.ready()
True
>>> a.get()
2
>>> a=add.delay(10,5)
>>> a.get()
15

6.實例

# views.py

from app.tasks import add,sendmail

def task_workorder(request, id):
    """任務添加"""
    # ......你的代碼......
    sendmail.delay(dict(to='asd@as.com'))  #申請人提交后會給審批人發(fā)郵件
    # ......你的代碼......

注意：如果執(zhí)行成功，你運行celery -A app.tasks worker –loglevel=info命令的終端會打印一些內(nèi)容；如果執(zhí)行失敗，報一大把紅色代碼。。。那么恭喜你！出錯了！這種錯誤，一般都是與你傳的參數(shù)相關，尤其在django框架下，不要將queryset這種數(shù)據(jù)查詢結果直接傳遞。

到此這篇關于Celery+django+redis異步執(zhí)行任務的實現(xiàn)示例的文章就介紹到這了,更多相關Celery+django+redis異步執(zhí)行內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: