摘要:前言针对高延时任务直接在一次网络请求中处理完毕会导致很不好的体验则可以不阻塞请求后台处理这些任务并且可以使用的进行数据库操作环境其他创建工程此时项目结构如下修改添加修改创建新创
前言: 针对高延时任务, 直接在一次网络请求中处理完毕会导致很不好的体验, celery则可以不阻塞请求后台处理这些任务, 并且可以使用django的models进行数据库操作.环境
python models:
celery-4.1.1
redis-2.10.6
django-1.11.7
其他:
redis-3.2.9
macos
python3.6
创建django工程django-admin startproject dc
cd dc
django-admin startapp main
此时项目结构如下
dc |-- __init__.py |-- main | |-- __init__.py | |-- admin.py | |-- apps.py | |-- migrations | | `-- __init__.py | |-- models.py | |-- tests.py | `-- views.py |-- settings.py |-- urls.py `-- wsgi.py
修改settings.py, 添加app
INSTALLED_APPS = [ "django.contrib.admin", "django.contrib.auth", "django.contrib.contenttypes", "django.contrib.sessions", "django.contrib.messages", "django.contrib.staticfiles", "dc.main" //new added ]
修改dc/main/models.py, 创建新models
from django.db import models # Create your models here. class Person(models.Model): first_name = models.CharField(max_length=30) last_name = models.CharField(max_length=30)
创建根访问节点
dc/main/views.py
from django.shortcuts import render from django.http import HttpResponse # Create your views here. def hello(request): return HttpResponse("hello world")
dc/urls.py
urlpatterns = [ url(r"^admin/", admin.site.urls), url(r"^$", hello) //new added ]
依次执行以下语句, 初始化django各功能模块
python manage.py migrate python manage.py makemigrations main python manage.py sqlmigrate main 0001 python manage.py migrate
接下来python manage.py runserver, 访问http://127.0.0.1:8000 即可看到hello world.
启动redisredis是作为celery中间件使用的, 用来存储消息队列.
redis解压后, 直接运行src/redis-server即可启动, 默认端口6379
配置celery参考文档
创建dc/celery.py
#-*- coding:utf-8 -*- import os from celery import Celery # set the default Django settings module for the "celery" program. os.environ.setdefault("DJANGO_SETTINGS_MODULE", "dc.settings") app = Celery("dc") # Using a string here means the worker doesn"t have to serialize # the configuration object to child processes. # - namespace="CELERY" means all celery-related configuration keys # should have a `CELERY_` prefix. app.config_from_object("django.conf:settings", namespace="CELERY") # Load task modules from all registered Django app configs. app.autodiscover_tasks()
修改 dc/__init__.py
from .celery import app as celery_app __all__ = ["celery_app"]
修改 dc/settings.py, 设定 redis URL
CELERY_BROKER_URL = "redis://127.0.0.1:6379/3"
创建dc/main/tasks.py
#-*- coding:utf-8 -*- from celery import shared_task @shared_task def test(): import time time.sleep(5) from dc.main.models import Person person = Person(first_name="smith", last_name="jhon") person.save() c = Person.objects.count() print(f"person count is {c}")
修改dc/main/views.py
def hello(request): from dc.main.tasks import test test.delay() return HttpResponse("hello world")
启动celery进程
celery -A dc worker -l info
接下来访问http://127.0.0.1:8000, 即可发现页面立刻返回, 并没有被time阻塞, 查看启动celery的窗口, 即可发现log以及打印的信息, 确定models可以正常使用.
おわり.
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/41826.html
摘要:上传文件概述当在处理文件上传时,文件的数据被存储在属性中只有在请求的方法为且提交的表单带有属性的情况才会包含数据。如豆瓣,防止页面卡死。 上传文件 概述 当Django在处理文件上传时,文件的数据被存储在request.FILES属性中 FILES只有在请求的方法为POST且提交的form表单带有enctype=multipart/form-data属性的情况才会包含数据。否则,FIL...
摘要:今天介绍一下如何在项目中使用搭建一个有两个节点的任务队列一个主节点一个子节点主节点发布任务,子节点收到任务并执行。 今天介绍一下如何在django项目中使用celery搭建一个有两个节点的任务队列(一个主节点一个子节点;主节点发布任务,子节点收到任务并执行。搭建3个或者以上的节点就类似了),使用到了celery,rabbitmq。这里不会单独介绍celery和rabbitmq中的知识了...
摘要:介绍应用举例是一个基于开发的分布式异步消息任务队列,通过它可以轻松的实现任务的异步处理,如果你的业务场景中需要用到异步任务,就可以考虑使用你想对台机器执行一条批量命令,可能会花很长时间,但你不想让你的程序等着结果返回, celery 1.celery介绍 1.1 celery应用举例 Celery 是一个 基于python开发的分布式异步消息任务队列,通过...
阅读 1504·2021-11-12 10:35
阅读 1556·2021-08-03 14:02
阅读 2611·2019-08-30 15:55
阅读 1992·2019-08-30 15:54
阅读 697·2019-08-30 14:01
阅读 2388·2019-08-29 17:07
阅读 2231·2019-08-26 18:37
阅读 2943·2019-08-26 16:51