Python 异步任务神器 Celery 结合Flask使用

2020年03月30日 11:28:49   [来源:互联网]   [阅读:1827]
字体:【

说在前头

用Python搞后台开发的,应该都知道celery的重要性。废话不多说,搞起。

安装

使用pip来安装,环境python3+

Flask-Celery-Helper==1.1.0
celery==4.1.0
redis==3.0.1

准备工作

目录结构
app
|-__init__.py
|-tasks.py
config.py
celery_runner.py

celery_runner.py

tasks.py

def task_demo():
print("执行到我了")

__init__.py

from flask_celery import Celery 

def create_app(config_name):
app = Flask(__name__)
db.app = app
app.config.from_object(config[config_name])
config[config_name].init_app(app)

celery.init_app(app) # 后台任务

config.py

import os

basedir = os.path.abspath(os.path.dirname(__file__))

class Config:
JSON_AS_ASCII = False
SECRET_KEY = os.environ.get('SECRET_KEY') or 'hard to guess string'
CELERY_BROKER_URL = 'redis://:密码@127.0.0.1:6379/11' #使用redis
CELERY_RESULT_BACKEND = 'redis://:密码@127.0.0.1:6379/11'#使用redis

@staticmethod
def init_app(app):
pass

class DevelopmentConfig(Config):
DEBUG = True

class TestingConfig(Config):
TESTING = True

class ProductionConfig(Config):
DEBUG = False

config = {
'development': DevelopmentConfig,
'testing': TestingConfig,
'production': ProductionConfig,
'default': DevelopmentConfig
}

使用

在根目录下开启celery服务

celery worker -c 2 -A celery_runner --loglevel=info

具体参数,独自去网上找。

调用:

task_demo.apply_async()

使用场景

1.就比如发邮箱这个例子吧。用户点击发邮箱后,后台异步去执行,而不是阻塞等到发完成功后才提示用户说邮箱发送成功。而是马上去异步执行发布邮箱,提示用户去查看邮箱。

2.导出大量订单。你可以后台去执行,并生成excel放在后台,之后提供给客户下载即可。又或者可以用长连接操作提示用户。

。。。

场景很多。我就不一一说明了。

说在最后

假如有帮助到你,或者你也是python爱好者,点赞,关注,转发。我会持续更新我日常在项目用到的工具,分享给大家。

推荐阅读:叶紫


相关新闻
新闻焦点
近年来,随着中国经济快速发展,化妆品市场呈现出一片红火景象,中国已成为全球化妆品消费第二大国。我国化妆品市场前期虽然起步较晚,但潜力不容小觑,许[更多]
近日,新浪与近20家全国头部地面频道、王牌民生节目、优秀的融媒体平台及自媒体平台签订融媒体深度战略合作协议,并宣布正式启动“温暖70城”活动。合[更多]
最近护肤界掀起了一股“国潮风”,最本人也对一款少女杀手面膜动心了,没管住自己的手入了名膜壹号的梦幻面膜。名膜壹号的面膜一直有不少小红书护肤达人的[更多]
【今年平均每人花44元看电影】截至12月14日,据灯塔专业版数据显示,国内累计电影票房已达609.6亿元,超过了去年全年606.88亿元的票房总[更多]
关于我们 | 联系我们 | XML地图 | 网站地图TXT | 版权声明
版权所有:科技杂谈网未经授权禁止复制或建立镜像
相关作品的原创性、文中陈述文字以及内容数据庞杂本站无法一一核实,如果您发现本网站上有侵犯您的合法权益的内容,请联系我们,本网站将立即予以删除!
中国互联网违法和不良信息举报中心 网络警察报警岗亭