Django celery實(shí)現(xiàn)異步任務(wù)操作,并在后臺(tái)運(yùn)行(守護(hù)進(jìn)程)
沒廢話，直接上代碼。
環(huán)境說明：
python3.6
django2.0.5
我們使用redis的作為celery任務(wù)隊(duì)列，有一個(gè)合成包可以直接安裝兩者一起使用需要的安裝包
直接在終端鍵入
pip install celery-with-redis
就可以安裝需要的依賴包了
構(gòu)建項(xiàng)目過程略過，直接開始進(jìn)行celery配置
一、celery配置。
我們的項(xiàng)目名稱為myproject，首先setting配置，添加
# celery settings # celery中間人 redis://redis服務(wù)所在的ip地址:端口/數(shù)據(jù)庫(kù)號(hào) BROKER_URL = 'redis://localhost:6379/3' # celery結(jié)果返回，可用于跟蹤結(jié)果 CELERY_RESULT_BACKEND = 'redis://localhost:6379/3' # celery內(nèi)容等消息的格式設(shè)置 CELERY_ACCEPT_CONTENT = ['application/json', ] CELERY_TASK_SERIALIZER = 'json' CELERY_RESULT_SERIALIZER = 'json' # celery時(shí)區(qū)設(shè)置，使用settings中TIME_ZONE同樣的時(shí)區(qū) CELERY_TIMEZONE = TIME_ZONE
然后在PATH/myproject/myproject/即setting的同級(jí)目錄下創(chuàng)建celery.py，初始化celery。
from __future__ import absolute_import, unicode_literals
from celery import Celery
from django.conf import settings
import os
# 獲取當(dāng)前文件夾名，即為該Django的項(xiàng)目名
project_name = os.path.split(os.path.abspath('.'))[-1]
project_settings = '%s.settings' % project_name
# 設(shè)置環(huán)境變量
os.environ.setdefault('DJANGO_SETTINGS_MODULE', project_settings)
# 實(shí)例化Celery
app = Celery(project_name)
# 使用django的settings文件配置celery
app.config_from_object('django.conf:settings')
# Celery加載所有注冊(cè)的應(yīng)用
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
這里第一行輸入不能換位置，只能在首行，否則會(huì)報(bào)錯(cuò)。
這里的實(shí)例化celery的app我們?cè)趧e處要導(dǎo)入，為了方便導(dǎo)入，我們把它放到__init__.py里，所以在/myproject/myproject/__init__.py我們加入
from __future__ import absolute_import, unicode_literals # 引入celery實(shí)例對(duì)象 from .celery import app as celery_app
這樣同時(shí)也能告知django celery.py文件的存在。
二、用celery裝飾我們的需要進(jìn)行的異步函數(shù)。
我們?cè)陧?xiàng)目根目錄下創(chuàng)建celery_tasks模塊，即在PATH/myproject/下創(chuàng)建該模塊，然后在該模塊下創(chuàng)建tasks.py，把我們的耗時(shí)程序?qū)戇M(jìn)去。
from myproject import celery_app
import time
@celery_app.task
def time_consuming_fun():
for i in range(5):
time.sleep(1)
print(i)
return 'ok'
直接用我們的celery_app下的task方法裝飾需要進(jìn)行異步處理的函數(shù)即可。
三、調(diào)用異步函數(shù)。
在view中調(diào)用，這里用的是Django的類視圖。
from celery_tasks.tasks import time_consuming_fun
from django.views import View
from django.http import JsonResponse
# Create your views here.
class MyView(View):
def get(self,request):
#異步調(diào)用
time_consuming_fun.delay()
#直接調(diào)用
#time_consuming_fun()
return JsonResponse({'msg':'ok','code':200})
配置好url即可。
四、啟動(dòng)celery。
在項(xiàng)目根目錄下，即managy同級(jí)文件目錄下，輸入命令：
celery -A myproject worker -l info
此時(shí)celery在終端窗口運(yùn)行，關(guān)閉終端celery就會(huì)停止。
輸入命令
celery multi start w1 -A myproject -l info --logfile = celerylog.log --pidfile = celerypid.pid
此時(shí)celery為守護(hù)進(jìn)程，日志記錄在celerylog.log里。
日志文件可以指定路徑PATH/celerylog.log，此時(shí)會(huì)在指定路徑下創(chuàng)建日志文件。進(jìn)程號(hào)文件類似。
停止或重啟將開始換為stop或restart即可，所以需記錄w1，即需記錄woker的名稱來方便重啟和停止。
補(bǔ)充：Django項(xiàng)目后臺(tái)不掛斷運(yùn)行
方法一：
1、進(jìn)入項(xiàng)目目錄下，運(yùn)行下面程序：
nohup python manage.py runserver 0.0.0.0:5008 &
nohup(no hang up)用途：不掛斷的運(yùn)行命令
&用途：在后臺(tái)運(yùn)行
nohup /root/start.sh &
在shell中回車后提示：
[~]$ appending output to nohup.out
原程序的的標(biāo)準(zhǔn)輸出被自動(dòng)改向到當(dāng)前目錄下的nohup.out文件，起到了log的作用。
注意：在nohup執(zhí)行成功后直接點(diǎn)擊關(guān)閉程序按鈕關(guān)閉終端，會(huì)斷掉該命令對(duì)應(yīng)的session，導(dǎo)致nohup對(duì)應(yīng)的進(jìn)程被通知一起shutdown。所以在使用nohup命令后臺(tái)運(yùn)行命令之后，需要使用exit正常退出當(dāng)前賬戶，這樣才能保證命令一直在后臺(tái)運(yùn)行。
方法二：這個(gè)比較高級(jí)，使用screen
1、安裝screen
yum install -y screen
2、新建一個(gè)screen
screen -S xiedi
這樣會(huì)新開一個(gè)窗口，然后執(zhí)行命令即可
python manage.py runserver 0.0.0.0:9000
3、重開一個(gè)窗口，列出所有screen進(jìn)程，如下
[root@docker ~]# screen -ls
There are screens on:
3029.xiedi (Attached)
4、如果想鏈接上這個(gè)會(huì)話，執(zhí)行命令即可
screen -r 3029
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教。
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了pygame實(shí)現(xiàn)五子棋游戲，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2019-10-10
Python3.9用pip安裝wordcloud庫(kù)失敗的解決過程
一般在命令行輸入pip install wordcloud 總會(huì)顯示安裝失敗,所以下面這篇文章主要給大家介紹了關(guān)于Python3.9用pip安裝wordcloud庫(kù)失敗的解決過程,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2022-06-06
這篇文章主要介紹了Python下載圖片并保存本地的兩種方式，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-05-05
本文主要介紹了一行代碼生成Tableau可視化圖表的方法，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04
mvc框架打造筆記之wsgi協(xié)議的優(yōu)缺點(diǎn)以及接口實(shí)現(xiàn)
這篇文章主要給大家介紹了關(guān)于mvc框架打造筆記之wsgi協(xié)議的優(yōu)缺點(diǎn)以及接口實(shí)現(xiàn)的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2018-08-08
Python編程中對(duì)文件和存儲(chǔ)器的讀寫示例
這篇文章主要介紹了Python編程中對(duì)文件和存儲(chǔ)器的讀寫示例,包括使用cPickle儲(chǔ)存器存儲(chǔ)對(duì)象的例子,需要的朋友可以參考下2016-01-01
python數(shù)據(jù)結(jié)構(gòu)輸入輸出及控制和異常
這篇文章主要介紹了python數(shù)據(jù)結(jié)構(gòu)輸入輸出及控制和異常,上一章節(jié)中我們介紹了python的基礎(chǔ)數(shù)據(jù)類型和集合數(shù)據(jù)類型，這章節(jié)給大家介紹一下python的輸入輸出、控制和異常，對(duì)數(shù)據(jù)類型感興趣的同學(xué)可以查看一下文章<BR>2021-12-12
本文主要介紹了Python做屏幕錄制工具的實(shí)現(xiàn)示例，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-06-06
Python基于SciPy庫(kù)實(shí)現(xiàn)統(tǒng)計(jì)分析與建模
SciPy是一個(gè)強(qiáng)大的Python庫(kù)，提供了豐富的科學(xué)計(jì)算和數(shù)據(jù)分析工具，本文我們將探討如何使用Python和SciPy庫(kù)進(jìn)行統(tǒng)計(jì)分析和建模，感興趣的可以學(xué)習(xí)一下2023-06-06
詳解python使用canvas實(shí)現(xiàn)移動(dòng)并綁定鍵盤
這篇文章主要為大家介紹了python使用canvas實(shí)現(xiàn)移動(dòng)并綁定鍵盤，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2021-12-12