現在繼續學習在整合的框架中如何使用celery.
在flask中整合celery需要做到兩點:
celery必須能順利載入初始化檔案。
由於celery程序的執行和flask程序的執行是相互獨立的,但是在框架中我們希望只使用乙份配置檔案,這樣可以簡化配置的工作。
from celery importcelery
from flask import
flask
)def
return
celery
#
from celery importcelery
from flask import
flask
celery =none
def
return
celery
def)
config_class =config_map[config_name]
#初始化celery
global
celery
解決:引入flask-celery-helper,幫助我們初始化celery物件;
安裝flask-celery-helper
pip install flask-celery-helper
#extensions.py
from flask_celery import
celery
#建立celery的例項
celery =celery()
#__init__.py
from extensions import
celery
def)
config_class =config_map[config_name]
##tasks.py
from extensions import
celery
@celery.task()
defadd(x,y):
return x + y
注意
#from tasks import
add"
/index")
defindex():
"""乙個測試的例項
"""print(add(3+6)) #
add函式也能做普通的函式使用
eegqueue
') #
傳送非同步任務,指定佇列
return
"ok!
"
#run_celery.py
import
develop
") #
from extensions import celery #
此時的celery物件已經在上下文中完成初始化
#找到celery例項的位置,指定worker,指定接收某個佇列的訊息,如果不指定則接收所有佇列的訊息
celery -a run_celery.celery worker -q eegqueue --loglevel=info
Flask外掛程式系列 Flask Mail
簡介 給使用者傳送郵件是 web 應用中最常見的任務之一,比如使用者註冊,找回密碼等。python 內建了乙個 smtplib 的模組,可以用來傳送郵件,這裡我們使用 flask mail,是因為它可以和 flask 整合,讓我們更方便地實現此功能。安裝 使用 pip 安裝 pip install ...
Flask常用外掛程式
flask特點 1 小而精的代表 2 基於werkzeug工具箱編寫的輕量級web開發框架,它主要面向需求簡單,專案周期短的web小應用 3 靈活,核心思想是flask只完成基本的功能,別的功能都是靠各種第三方外掛程式來完成的,實現了模組高度化定製 常用的flask外掛程式如下 flask sqla...
flask系列之專案框架
flask作為乙個小巧的web框架受到很多人喜愛,這裡講一下flask開發web應用時的乙個典型框架,從總體上把握結構 上面就是乙個典型的結構。其次,templates作為乙個固定的資料夾,儲存了所有的html檔案,所有的返回模板的方法都會從這個資料夾開始找而且預設是作為模板的根檔案。我們還可以看到...