Django——小结
课程介绍
mvc
mvc框架的核心思想是:解耦,让不同的代码块之间降低耦合,增强代码的可扩展性和可移植性,实现向后兼容
- m:model,主要封装对数据库层的访问,对数据库中的数据进行增、删、改、查操作
- v:view,用于封装结果,生成页面展示的html内容
- c:controller,用于接收请求,处理业务逻辑,与model和view交互,返回结果
django-mvt
- m:model,与mvc中的m功能相同,负责和数据库交互,进行数据处理
- v:view,与mvc中的c功能相同,接收请求,进行业务处理,返回应答
- t:template,与mvc中的v功能相同,负责封装构造要返回的html
mvvm
- 出现原因:由于前端开发混合了html、css和javascript,而且页面众多,所以,代码的组织和维护难度其实更加复杂
- 好处:改变javascript对象的状态,会导致dom结构作出对应的变化,关注点就从如何操作dom变成了如何更新javascript对象的状态
- mvvm的设计思想:关注model的变化,让mvvm框架去自动更新dom的状态,从而把开发者从操作dom的繁琐步骤中解脱出来
- 结构:借鉴桌面应用程序的mvc思想,在前端页面中,把model用纯javascript对象表示,view负责显示,两者做到了最大限度的分离
- 使用:把model和view关联起来的就是viewmodel。viewmodel负责把model的数据同步到view显示出来,还负责把view的修改同步回model
入门
设计模型
orm框架
- o是object,也就类对象的意思
- r是relation,翻译成中文是关系,也就是关系数据库中数据表的意思
- m是mapping,是映射的意思
在orm框架中,它帮我们把类和数据表进行了一个映射,可以让我们通过类和类对象就能操作它所对应的表格中的数据。orm框架还有一个功能,它可以根据我们设计的类自动帮我们生成数据库中的表格,省去了我们自己建表的过程
- 使用django进行数据库开发的步骤如下
- 在models.py中定义模型类
- 迁移
- 通过类和对象完成数据增删改查操作
说明:不需要定义主键列,在生成时会自动添加,并且值为自动增长
数据表的默认名称为:<app_name>_<model_name>
一对多的关系(foreignkey)应定义在多的那个类中
管理站点
注册模型类
登录后台管理后,默认没有我们创建的应用中定义的模型类,需要在自己应用中的admin.py文件中注册,才可以在后台管理中看到,并进行增删改查操作
自定义管理页面
django提供了自定义管理页面的功能,比如列表页要显示哪些值
- /admin.py文件代码如下
1 from django.contrib import admin 2 from booktest.models import bookinfo,heroinfo 3 4 class bookinfoadmin(admin.modeladmin): 5 list_display = ['id', 'btitle', 'bpub_date'] 6 class heroinfoadmin(admin.modeladmin): 7 list_display = ['id', 'hname','hgender','hcomment'] 8 9 admin.site.register(bookinfo,bookinfoadmin) 10 admin.site.register(heroinfo,heroinfoadmin)
模型
数据库连接
/settings.py文件,找到databases项,默认使用sqlite3数据库
修改为使用mysql数据库,代码如下: 将引擎改为mysql,提供连接的主机host、端口port、数据库名name、用户名user、密码password。
databases = {
'default': {
'engine': 'django.db.backends.mysql',
'name': 'test2', #数据库名字,
'user': 'root', #数据库登录用户名
'password': 'mysql', #数据库登录密码
'host': 'localhost', #数据库所在主机
'port': '3306', #数据库端口
}
}
注意:数据库test2 django框架不会自动生成,需要我们自己进入mysql数据库去创建
模型类
字段类型
使用时需要引入django.db.models包,字段类型如下:
autofield:自动增长的integerfield,通常不用指定,不指定时django会自动创建属性名为id的自动增长属性。
booleanfield:布尔字段,值为true或false。
nullbooleanfield:支持null、true、false三种值。
charfield(max_length=字符长度):字符串。
参数max_length表示最大字符个数。
textfield:大文本字段,一般超过4000个字符时使用。
integerfield:整数。
decimalfield(max_digits=none, decimal_places=none):十进制浮点数。
参数max_digits表示总位数。
参数decimal_places表示小数位数。
floatfield:浮点数。
datefield[auto_now=false, auto_now_add=false]):日期。
参数auto_now表示每次保存对象时,自动设置该字段为当前时间,用于"最后一次修改"的时间戳,它总是使用当前日期,默认为false。
参数auto_now_add表示当对象第一次被创建时自动设置当前时间,用于创建的时间戳,它总是使用当前日期,默认为false。
参数auto_now_add和auto_now是相互排斥的,组合将会发生错误。
timefield:时间,参数同datefield。
datetimefield:日期时间,参数同datefield。
filefield:上传文件字段。
imagefield:继承于filefield,对上传的内容进行校验,确保是有效的图片。
选项
通过选项实现对字段的约束,选项如下:
null:如果为true,表示允许为空,默认值是false。
blank:如果为true,则该字段允许为空白,默认值是false。
对比:null是数据库范畴的概念,blank是表单验证范畴的。
db_column:字段的名称,如果未指定,则使用属性的名称。
db_index:若值为true, 则在表中会为此字段创建索引,默认值是false。
default:默认值。
primary_key:若为true,则该字段会成为模型的主键字段,默认值是false,一般作为autofield的选项使用。
unique:如果为true, 这个字段在表中必须有唯一值,默认值是false。
条件查询
条件运算符
查询等
1 list=bookinfo.objects.filter(id__exact=1) 2 可简写为: 3 list=bookinfo.objects.filter(id=1)
模糊查询
说明:如果要包含%无需转义,直接写即可
- contains:是否包含
list = bookinfo.objects.filter(btitle__contains='传')
- startswith、endswith:以指定值开头或结尾
1 list = bookinfo.objects.filter(btitle__endswith='部')
以上运算符都区分大小写,在这些运算符前加上i表示不区分大小写,如iexact、icontains、istartswith、iendswith
空查询
- isnull:是否为null
list = bookinfo.objects.filter(btitle__isnull=false)
范围查询
- in:是否包含在范围内
1 list = bookinfo.objects.filter(id__in=[1, 3, 5])
比较查询
- gt、gte、lt、lte:大于、大于等于、小于、小于等于
list = bookinfo.objects.filter(id__gt=3)
- 不等于的运算符,使用exclude()过滤器
1 list = bookinfo.objects.exclude(id=3)
日期查询
- year、month、day、week_day、hour、minute、second:对日期时间类型的属性进行运算
list = bookinfo.objects.filter(bpub_date__year=1980) list = bookinfo.objects.filter(bpub_date__gt=date(1990, 1, 1))
f对象
两个属性比较使用f对象
1 list = bookinfo.objects.filter(bread__gte=f('bcomment')) 2 list = bookinfo.objects.filter(bread__gt=f('bcomment') * 2)
q对象
多个过滤器逐个调用表示逻辑与关系,同sql语句中where部分的and关键字
1 list=bookinfo.objects.filter(bread__gt=20,id__lt=3) 2 或 3 list=bookinfo.objects.filter(bread__gt=20).filter(id__lt=3) 4 5 list = bookinfo.objects.filter(q(bread__gt=20) | q(pk__lt=3)) 6 7 q对象前可以使用~操作符,表示非not 8 list = bookinfo.objects.filter(~q(pk=3))
聚合函数
使用aggregate()过滤器调用聚合函数。聚合函数包括:avg,count,max,min,sum,被定义在django.db.models中
list = bookinfo.objects.aggregate(sum('bread'))
注意aggregate的返回值是一个字典类型,格式如下:
{'聚合类小写__属性名':值} 如:{'sum__bread':3}
使用count时一般不使用aggregate()过滤器,count函数的返回值是一个数字
list = bookinfo.objects.count()
查询集
返回查询集的过滤器
all():返回所有数据。
filter():返回满足条件的数据。
exclude():返回满足条件之外的数据,相当于sql语句中where部分的not关键字。
order_by():对结果进行排序
返回单个值的过滤器
get():返回单个满足条件的对象
如果未找到会引发"模型类.doesnotexist"异常。
如果多条被返回,会引发"模型类.multipleobjectsreturned"异常。
count():返回当前查询结果的总条数。
aggregate():聚合,返回一个字典。
判断某一个查询集中是否有数据
exists():判断查询集中是否有数据,如果有则返回true,没有则返回false
两大特性
惰性执行:创建查询集不会访问数据库,直到调用数据时,才会访问数据库,调用数据的情况包括迭代、序列化、与if合用。 缓存:使用同一个查询集,第一次使用时会发生数据库的查询,然后把结果缓存下来,再次使用这个查询集时会使用缓存的数据
查询集的缓存
每个查询集都包含一个缓存来最小化对数据库的访问。 在新建的查询集中,缓存为空,首次对查询集求值时,会发生数据库查询,django会将查询的结果存在查询集的缓存中,并返回请求的结果,接下来对查询集求值将重用缓存中的结果。
限制查询集
可以对查询集进行取下标或切片操作,等同于sql中的limit和offset子句。
注意:不支持负数索引。
对查询集进行切片后返回一个新的查询集,不会立即执行查询。
如果获取一个对象,直接使用[0],等同于[0:1].get(),但是如果没有数据,[0]引发indexerror异常,[0:1].get()如果没有数据引发doesnotexist异常。
示例:获取第1、2项,运行查看。
list=bookinfo.objects.all()[0:2]
模型类扩展
元选项
#定义图书模型类bookinfo
class bookinfo(models.model):
...
#定义元选项
class meta:
db_table='bookinfo' #指定bookinfo生成的数据表名为bookinfo
视图
urlconf
位置参数
1 url(r'^delete(\d+)/$',views.show_arg) 2 def show_arg(request,id): 3 return httpresponse('show arg %s'%id)
关键字参数
1 url(r'^delete(?p<id1>\d+)/$',views.show_arg) 2 def show_arg(request,id1): 3 return httpresponse('show %s'%id1)
httprequest对象
属性
下面除非特别说明,属性都是只读的
path:一个字符串,表示请求的页面的完整路径,不包含域名和参数部分。
method:一个字符串,表示请求使用的http方法,常用值包括:'get'、'post'。
在浏览器中给出地址发出请求采用get方式,如超链接。
在浏览器中点击表单的提交按钮发起请求,如果表单的method设置为post则为post请求。
encoding:一个字符串,表示提交的数据的编码方式。
如果为none则表示使用浏览器的默认设置,一般为utf-8。
这个属性是可写的,可以通过修改它来修改访问表单数据使用的编码,接下来对属性的任何访问将使用新的encoding值。
get:querydict类型对象,类似于字典,包含get请求方式的所有参数。
post:querydict类型对象,类似于字典,包含post请求方式的所有参数。
files:一个类似于字典的对象,包含所有的上传文件。
cookies:一个标准的python字典,包含所有的cookie,键和值都为字符串。
session:一个既可读又可写的类似于字典的对象,表示当前的会话,只有当django 启用会话的支持时才可用,详细内容见"状态保持"。
httpresponse对象
属性
content:表示返回的内容。
charset:表示response采用的编码字符集,默认为utf-8。
status_code:返回的http响应状态码。
content-type:指定返回数据的的mime类型,默认为'text/html'。
方法
_init_:创建httpresponse对象后完成返回内容的初始化。
set_cookie:设置cookie信息。
set_cookie(key, value='', max_age=none, expires=none)
cookie是网站以键值对格式存储在浏览器中的一段纯文本信息,用于实现用户跟踪。
max_age是一个整数,表示在指定秒数后过期。
expires是一个datetime或timedelta对象,会话将在这个指定的日期/时间过期。
max_age与expires二选一。
如果不指定过期时间,在关闭浏览器时cookie会过期。
delete_cookie(key):删除指定的key的cookie,如果key不存在则什么也不发生。
write:向响应体中写数据。
状态保持
- 浏览器请求服务器是无状态的。
- 无状态指一次用户请求时,浏览器、服务器无法知道之前这个用户做过什么,每次请求都是一次新的请求。
- 无状态的应用层面的原因是:浏览器和服务器之间的通信都遵守http协议。
- 根本原因是:浏览器与服务器是使用socket套接字进行通信的,服务器将请求结果返回给浏览器之后,会关闭当前的socket连接,而且服务器也会在处理页面完毕之后销毁页面对象
有时需要保存下来用户浏览的状态,比如用户是否登录过,浏览过哪些商品等。 实现状态保持主要有两种方式
- 在客户端存储信息使用cookie
- 在服务器端存储信息使用session
状态保持
cookie
- 指某些网站为了辨别用户身份、进行session跟踪而储存在用户本地终端上的数据(通常经过加密)
- cookie是由服务器端生成,发送给user-agent(一般是浏览器),浏览器会将cookie的key/value保存到某个目录下的文本文件内,下次请求同一网站时就发送该cookie给服务器(前提是浏览器设置为启用cookie)
- cookie名称和值可以由服务器端开发自己定义,这样服务器可以知道该用户是否是合法用户以及是否需要重新登录等
- 服务器可以利用cookies包含信息的任意性来筛选并经常性维护这些信息,以判断在http传输中的状态。cookies最典型记住用户名
cookie的特点
- cookie以键值对的格式进行信息的存储
- cookie基于域名安全,不同域名的cookie是不能互相访问的
- 当浏览器请求某网站时,会将浏览器存储的跟网站相关的所有cookie信息提交给网站服务器
设置cookie
response.set_cookie('h1', '你好')
读取cookie
response.write('<h1>' + request.cookies['h1'] + '</h1>')
session
在服务器端进行状态保持的方案就是session
启用session
django项目默认启用session
- /settings.py文件,在项middleware_classes中启用session中间件
存储方式
/settings.py文件,设置session_engine项指定session数据存储的方式,可以存储在数据库、缓存、redis等
- 存储在数据库中,如下设置可以写,也可以不写,这是默认存储方式
session_engine='django.contrib.sessions.backends.db'
- 存储在缓存中:存储在本机内存中,如果丢失则不能找回,比数据库的方式读写更快
session_engine='django.contrib.sessions.backends.cache'
- 混合存储:优先从本机内存中存取,如果没有则从数据库中存取
session_engine='django.contrib.sessions.backends.cached_db'
- 如果存储在数据库中,需要在项installed_apps中安装session应用
- 迁移后会在数据库中创建出存储session的表
- 由表结构可知,操作session包括三个数据:键,值,过期时间
依赖于cookie
所有请求者的session都会存储在服务器中,服务器如何区分请求者和session数据的对应关系呢?
-
在使用session后,会在cookie中存储一个sessionid的数据,每次请求时浏览器都会将这个数据发给服务器,服务器在接收到sessionid后,会根据这个值找出这个请求者的session
-
结果:如果想使用session,浏览器必须支持cookie,否则就无法使用session了
-
存储session时,键与cookie中的sessionid相同,值是开发人员设置的键值对信息,进行了base64编码,过期时间由开发人员设置
对象及方法
通过httprequest对象的session属性进行会话的读写操作
- 以键值对的格式写session
request.session['键']=值
- 根据键读取值
request.session.get('键',默认值)
- 清除所有session,在存储中删除值部分
request.session.clear()
- 清除session数据,在存储中删除session的整条数据
request.session.flush()
- 删除session中的指定键及值,在存储中只删除某个键及对应的值
del request.session['键']
- 设置会话的超时时间,如果没有指定过期时间则两个星期后过期
设置会话的超时时间,如果没有指定过期时间则两个星期后过期
- value
- 如果value是一个整数,会话将在value秒没有活动后过期
- 如果value为0,那么用户会话的cookie将在用户的浏览器关闭时过期
- 如果value为none,那么会话永不过期
使用redis存储session
会话还支持文件、纯cookie、memcached、redis等方式存储
- 安装包
pip install django-redis-sessions==0.5.6
- /settings文件,增加如下项:
session_engine = 'redis_sessions.session' session_redis_host = 'localhost' session_redis_port = 6379 session_redis_db = 2 session_redis_password = '' session_redis_prefix = 'session'
模板
模板语言
标签
-
for标签语法如下: {%for item in 列表%} 循环逻辑 {{forloop.counter}}表示当前是第几次循环,从1开始 {%empty%} 列表为空或不存在时执行此逻辑 {%endfor%} if标签语法如下: {%if ...%} 逻辑1 {%elif ...%} 逻辑2 {%else%} 逻辑3 {%endif%}
过滤器
变量|过滤器:参数
- 长度length,返回字符串包含字符的个数,或列表、元组、字典的元素个数
- 默认值default,如果变量不存在时则返回默认值
data|default:'默认值'
日期date,用于对日期类型的值进行字符串格式化,常用的格式化字符如下:
y表示年,格式为4位,y表示两位的年。
m表示月,格式为01,02,12等。
d表示日, 格式为01,02等。
j表示日,格式为1,2等。
h表示时,24进制,h表示12进制的时。
i表示分,为0-59。
s表示秒,为0-59。
value|date:"y年m月j日 h时i分s秒"
html转义
关闭转义
过滤器escape可以实现对变量的html转义,默认模板就会转义,一般省略
{{t1|escape}}
过滤器safe:禁用转义,告诉模板这个变量是安全的,可以解释执行
{{data|safe}}
标签autoescape:设置一段代码都禁用转义,接受on、off参数
{%autoescape off%} ... {%endautoescape%}
csrf
csrf全拼为cross site request forgery,译为跨站请求伪造。csrf指攻击者盗用了你的身份,以你的名义发送恶意请求
验证码
手动实现验证码
- /views.py文件中,创建视图verify_code
- 随机生成字符串后存入session中,用于后续判断
- 视图返回mime-type为image/png
1 from pil import image, imagedraw, imagefont 2 from django.utils.six import bytesio 3 ... 4 def verify_code(request): 5 #引入随机函数模块 6 import random 7 #定义变量,用于画面的背景色、宽、高 8 bgcolor = (random.randrange(20, 100), random.randrange( 9 20, 100), 255) 10 width = 100 11 height = 25 12 #创建画面对象 13 im = image.new('rgb', (width, height), bgcolor) 14 #创建画笔对象 15 draw = imagedraw.draw(im) 16 #调用画笔的point()函数绘制噪点 17 for i in range(0, 100): 18 xy = (random.randrange(0, width), random.randrange(0, height)) 19 fill = (random.randrange(0, 255), 255, random.randrange(0, 255)) 20 draw.point(xy, fill=fill) 21 #定义验证码的备选值 22 str1 = 'abcd123efghijk456lmnopqrs789tuvwxyz0' 23 #随机选取4个值作为验证码 24 rand_str = '' 25 for i in range(0, 4): 26 rand_str += str1[random.randrange(0, len(str1))] 27 #构造字体对象,ubuntu的字体路径为“/usr/share/fonts/truetype/freefont” 28 font = imagefont.truetype('freemono.ttf', 23) 29 #构造字体颜色 30 fontcolor = (255, random.randrange(0, 255), random.randrange(0, 255)) 31 #绘制4个字 32 draw.text((5, 2), rand_str[0], font=font, fill=fontcolor) 33 draw.text((25, 2), rand_str[1], font=font, fill=fontcolor) 34 draw.text((50, 2), rand_str[2], font=font, fill=fontcolor) 35 draw.text((75, 2), rand_str[3], font=font, fill=fontcolor) 36 #释放画笔 37 del draw 38 #存入session,用于做进一步验证 39 request.session['verifycode'] = rand_str 40 #内存文件操作 41 buf = bytesio() 42 #将图片保存在内存中,文件类型为png 43 im.save(buf, 'png') 44 #将内存中的图片数据返回给客户端,mime类型为图片png 45 return httpresponse(buf.getvalue(), 'image/png')
验证
- /views.py文件中,创建视图verify_yz
1 def verify_yz(request): 2 yzm=request.post.get('yzm') 3 verifycode=request.session['verifycode'] 4 response=httpresponse('no') 5 if yzm==verifycode: 6 response=httpresponse('ok') 7 return response
换验证码
<script type="text/javascript" src="/static/jquery-1.12.4.min.js"></script> <script type="text/javascript"> $(function(){ $('#change').css('cursor','pointer').click(function() { $('#yzm').attr('src',$('#yzm').attr('src')+1) }); }); </script> ... <img id="yzm" src="/verify_code/?1"/> <span id="change">看不清,换一个</span>
反向解析
在定义url时,需要为include定义namespace属性,为url定义name属性,使用时,在模板中使用url标签,在视图中使用reverse函数,根据正则表达式动态生成地址,减轻后期维护成本
url(r'^',include('booktest.urls',namespace='booktest'))
url(r'^fan2/$', views.fan2,name='fan2')
反向解析:<a href="{%url 'booktest:fan2'%}">fan2</a>
return redirect(reverse('booktest:fan2'))
常用
静态文件处理
- /settings.py文件中定义静态文件存放的物理目录
static_url = '/static/' staticfiles_dirs = [ os.path.join(base_dir, 'static'), ]
分页
paginator类实例对象
方法_init_(列表,int):返回分页对象,第一个参数为列表数据,第二个参数为每页数据的条数。
属性count:返回对象总数。
属性num_pages:返回页面总数。
属性page_range:返回页码列表,从1开始,例如[1, 2, 3, 4]。
方法page(m):返回page类实例对象,表示第m页的数据,下标以1开始
page类实例对象
调用paginator对象的page()方法返回page对象,不需要手动构造。
属性object_list:返回当前页对象的列表。
属性number:返回当前是第几页,从1开始。
属性paginator:当前页对应的paginator对象。
方法has_next():如果有下一页返回true。
方法has_previous():如果有上一页返回true。
方法len():返回当前页面对象的个数。
示例
- /views.py文件中创建视图page_test
1 from django.core.paginator import paginator 2 from booktest.models import areainfo 3 ... 4 #参数pindex表示:当前要显示的页码 5 def page_test(request,pindex): 6 #查询所有的地区信息 7 list1 = areainfo.objects.filter(aparent__isnull=true) 8 #将地区信息按一页10条进行分页 9 p = paginator(list1, 10) 10 #如果当前没有传递页码信息,则认为是第一页,这样写是为了请求第一页时可以不写页码 11 if pindex == '': 12 pindex = '1' 13 #通过url匹配的参数都是字符串类型,转换成int类型 14 pindex = int(pindex) 15 #获取第pindex页的数据 16 list2 = p.page(pindex) 17 #获取所有的页码信息 18 plist = p.page_range 19 #将当前页码、当前页的数据、页码信息传递到模板中 20 return render(request, 'booktest/page_test.html', {'list': list2, 'plist': plist, 'pindex': pindex})
- /urls.py文件中配置url
url(r'^page(?p<pindex>[0-9]*)/$', views.page_test)
- 创建page_test.html模板文件
<html> <head> <title>分页</title> </head> <body> 显示当前页的地区信息:<br> <ul> {%for area in list%} <li>{{area.id}}--{{area.atitle}}</li> {%endfor%} </ul> <hr> 显示页码信息:当前页码没有链接,其它页码有链接<br> {%for pindex in plist%} {%if pindex == pindex%} {{pindex}} {%else%} <a href="/page{{pindex}}/">{{pindex}}</a> {%endif%} {%endfor%} </body> </html>
示例:省市区选择
1 <html> 2 <head> 3 <title>省市区列表</title> 4 <script type="text/javascript" src="/static/js/jquery-1.12.4.min.js"></script> 5 <script type="text/javascript"> 6 $(function(){ 7 //页面加载完成后获取省信息,并添加到省select 8 $.get('/area2/',function(dic) { 9 pro=$('#pro') 10 $.each(dic.data,function(index,item){ 11 pro.append('<option value='+item[0]+'>'+item[1]+'</option>'); 12 }) 13 }); 14 //为省select绑定change事件,获取市信息,并添加到市select 15 $('#pro').change(function(){ 16 $.get('/area3_'+$(this).val()+'/',function(dic){ 17 city=$('#city'); 18 city.empty().append('<option value="">请选择市</option>'); 19 dis=$('#dis'); 20 dis.empty().append('<option value="">请选择区县</option>'); 21 $.each(dic.data,function(index,item){ 22 city.append('<option value='+item[0]+'>'+item[1]+'</option>'); 23 }) 24 }); 25 }); 26 //为市select绑定change事件,获取区县信息,并添加到区县select 27 $('#city').change(function(){ 28 $.get('/area3_'+$(this).val()+'/',function(dic){ 29 dis=$('#dis'); 30 dis.empty().append('<option value="">请选择区县</option>'); 31 $.each(dic.data,function(index,item){ 32 dis.append('<option value='+item[0]+'>'+item[1]+'</option>'); 33 }) 34 }) 35 }); 36 37 }); 38 </script> 39 </head> 40 <body> 41 <select id="pro"> 42 <option value="">请选择省</option> 43 </select> 44 <select id="city"> 45 <option value="">请选择市</option> 46 </select> 47 <select id="dis"> 48 <option value="">请选择区县</option> 49 </select> 50 </body> 51 </html
celery
情景:用户发起request,并等待response返回。在本些views中,可能需要执行一段耗时的程序,那么用户就会等待很长时间,造成不好的用户体验,比如发送邮件、手机验证码等
celery名词
- 任务task:就是一个python函数
- 队列queue:将需要执行的任务加入到队列中
- 工人worker:在一个新进程中,负责执行队列中的任务
- 代理人broker:负责调度,在布置环境中使用redis
- /settings.py中安装
installed_apps = ( ... 'djcelery', }
- /settings.py文件中配置代理和任务模块
import djcelery djcelery.setup_loader() broker_url = 'redis://127.0.0.1:6379/2'
- 创建tasks.py文件
1 import time 2 from celery import task 3 4 @task 5 def sayhello(): 6 print('hello ...') 7 time.sleep(2) 8 print('world ...')
- /views.py文件,修改sayhello视图
1 from booktest import tasks 2 ... 3 def sayhello(request): 4 # print('hello ...') 5 # time.sleep(2) 6 # print('world ...') 7 tasks.sayhello.delay() 8 return httpresponse("hello world")
- 执行迁移生成celery需要的数据表
python manage.py migrate
- 启动redis,如果已经启动则不需要启动
sudo service redis start
- 启动worker
python manage.py celery worker --loglevel=info
- 修改为发送邮件的代码,就可以实现无阻塞发送邮件
1 from django.conf import settings 2 from django.core.mail import send_mail 3 from celery import task 4 5 @task 6 def sayhello(): 7 msg='<a href="http://www.itcast.cn/subject/pythonzly/index.shtml" target="_blank">点击激活</a>' 8 send_mail('注册激活','',settings.email_from, 9 ['itcast88@163.com'], 10 html_message=msg)
请使用手机"扫一扫"x
上一篇: 逗B搞的笑,水平相当有保证啊!
推荐阅读
-
图论小结(一)包括一些最短路,最小生成树,差分约束,欧拉回路,的经典题和变种题。强连通,双连通,割点割桥的应用。二分匹配
-
javascript读取文本节点方法小结
-
百度算法调整不断 担心百度k站的一些原因小结
-
解决explorer.exe 应用程序错误,内存不能为 read或written的解决方法小结
-
Visual Studio 2010 正式版激活的两种方法小结
-
scikit-learn使用笔记与sign prediction简单小结
-
Linux后台进程管理的一些命令小结
-
C#打印PDF文档的10种方法(小结)
-
Windows7 系统安装的各种方法小结
-
从SEO的角度谈网站改版需要注意的问题小结