当前位置:   article > 正文

Django框架之DRF框架(最新)_django drf

django drf

一、前言

在讲DRF框架之前先简单了解一下下面内容:

1、Web应用模式

在WEB开发应用中,有2种应用模式:前后端不分离、前后端分离

前后端不分离(客户端看到的内容和所有界面效果都是由服务端提供出来的)

前后端分离(前端的界面效果(html,css,js)分离到另外一个服务器,python服务器只需要分会数据即可)

前端形成一个独立的万盏,服务的构成一个独立的网站

2、api接口

API(Application Programming Interface)是应用程序开发接口的缩写,意思是一些预设好的函数或方法,这些预设好的函数或方法允许第三方程序通过网络来调用数据或提供基于数据的服务。

API分为很多类别,比如:操作系统API、Web API、平台API等等。对于Web API,它是一种通过网络访问后端系统的电子接口,其中可以包含一些众所周知的Web标准(如HTTP、XML、JSON等)。

3、RESTful API规范

RESTful API通常根据 GET/POST/PUT/DELETE 来区分操作资源的动作,是一种风格,而不是一种约束和规约

统一接口:

GET(SELECT):从服务器查询,可以在服务器通过请求的参数区分查询的方式。
POST(CREATE):在服务器新建一个资源,调用insert操作。
PUT(UPDATE):在服务器更新资源,调用update操作。
PATCH(UPDATE):在服务器更新资源(客户端提供改变的属性)。(目前jdk7未实现,tomcat7也不行)。
DELETE(DELETE):从服务器删除资源,调用delete语句。

状态码和返回数据:

主要分为五大类:
1xx:相关信息

100:(继续) 请求者应当继续提出请求。 服务器返回此代码表示已收到请求的第一部分,正在等待其余部分。

101:(切换协议) 请求者已要求服务器切换协议,服务器已确认并准备切换。

102:由WebDAV(RFC 2518)扩展的状态码,代表处理将被继续执行。


2xx:操作成功

200:(成功) 服务器已成功处理了请求。 通常,这表示服务器提供了请求的网页。

201:(已创建) 请求成功并且服务器创建了新的资源。

202:(已接受) 服务器已接受请求,但尚未处理。

203:(非授权信息) 服务器已成功处理了请求,但返回的信息可能来自另一来源。

204:(无内容) 服务器成功处理了请求,但没有返回任何内容。

205:(重置内容) 服务器成功处理了请求,但没有返回任何内容。

206:(部分内容) 服务器成功处理了部分 GET 请求。

208:(已经报告)一个DAV的绑定成员被前一个请求枚举,并且没有被再一次包括。

226:(IM Used)服务器已经满足了请求所要的资源,并且响应是一个或者多个实例操作应用于当前实例的结果。


3xx:重定向

300:(多种选择) 针对请求,服务器可执行多种操作。 服务器可根据请求者 (user agent) 选择一项操作,或提供操作列表供请求者选择。

301:(永久移动) 请求的网页已永久移动到新位置。 服务器返回此响应(对 GET 或 HEAD 请求的响应)时,会自动将请求者转到新位置。

302:(临时移动) 服务器目前从不同位置的网页响应请求,但请求者应继续使用原有位置来进行以后的请求。

303:(查看其他位置) 请求者应当对不同的位置使用单独的 GET 请求来检索响应时,服务器返回此代码。

304:(未修改) 自从上次请求后,请求的网页未修改过。 服务器返回此响应时,不会返回网页内容。

305:(使用代理) 请求者只能使用代理访问请求的网页。 如果服务器返回此响应,还表示请求者应使用代理。

307:(临时重定向) 服务器目前从不同位置的网页响应请求,但请求者应继续使用原有位置来进行以后的请求。

308:(永久转移)这个请求和以后的请求都应该被另一个URI地址重新发送。307、308和302、301有相同的表现,但是不允许HTTP方法改变。例如,请求表单到一个永久转移的资源将会继续顺利地执行。


4xx:客户端错误

400:(错误请求) 服务器不理解请求的语法。

401:(未授权) 请求要求身份验证。 对于需要登录的网页,服务器可能返回此响应。

402:该状态码是为了将来可能的需求而预留的。

403:(禁止) 服务器拒绝请求。

404:(未找到) 服务器找不到请求的网页。

405:(方法禁用) 禁用请求中指定的方法。

406:(不接受) 无法使用请求的内容特性响应请求的网页。

407:(需要代理授权) 此状态代码与 401(未授权)类似,但指定请求者应当授权使用代理。

408:(请求超时) 服务器等候请求时发生超时。

409:(冲突) 服务器在完成请求时发生冲突。 服务器必须在响应中包含有关冲突的信息。

410:(已删除) 如果请求的资源已永久删除,服务器就会返回此响应。

411:(需要有效长度) 服务器不接受不含有效内容长度标头字段的请求。

412:(未满足前提条件) 服务器未满足请求者在请求中设置的其中一个前提条件。

413:(请求实体过大) 服务器无法处理请求,因为请求实体过大,超出服务器的处理能力。

414:(请求的 URI 过长) 请求的 URI(通常为网址)过长,服务器无法处理。

415:(不支持的媒体类型) 请求的格式不受请求页面的支持。

416:(请求范围不符合要求) 如果页面无法提供请求的范围,则服务器会返回此状态代码。

417:(未满足期望值) 服务器未满足"期望"请求标头字段的要求。

418:(我是一个茶壶)这个代码是在1998年作为传统的IETF April Fools‘ jokes被定义的在RFC2324,超文本咖啡罐控制协议,但是并没有被实际的HTTP服务器实现。RFC指定了这个代码应该是由茶罐返回给速溶咖啡。

419:(认证超时)并不是HTTP标注的一部分,419认证超时表示以前的有效证明已经失效了。同时也被用于401未认证的替代选择为了从其它被拒绝访问的已认证客户端中指定服务器的资源。

420:(方法失效)不是HTTP的标准,但是被Spring定义在HTTP状态类中当方法失时使用。这个状态码已经不推荐在Spring中使用。

420:(提高你的耐心)也不是HTTP标准的一部分,但是被版本1的Twitter搜索和趋势APi返回当客户端的速率被限制的时候。其它的服务提供商可能会使用429太多的请求响应码来代替。

421:从当前客户端所在的IP地址到服务器的连接数超过了服务器许可的最大范围。通常,这里的IP地址指的是从服务器上看到的客户端地址(比如用户的网关或者代理服务器地址)。在这种情况下,连接数的计算可能涉及到不止一个终端用户。

422:请求格式正确,但是由于含有语义错误,无法响应。(RFC 4918 WebDAV)423 Locked

当前资源被锁定。(RFC 4918 WebDAV)

424:由于之前的某个请求发生的错误,导致当前请求失败,例如 PROPPATCH。(RFC 4918 WebDAV)

425:在WebDav Advanced Collections 草案中定义,但是未出现在《WebDAV 顺序集协议》(RFC 3658)中。

426:客户端应当切换到TLS/1.0。(RFC 2817)

428:(需要前置条件)原始服务器需要有条件的请求。当客户端GET一个资源的状态的时候,同时又PUT回给服务器,与此同时第三方修改状态到服务器上的时候,为了避免丢失更新的问题发生将会导致冲突。

429:(过多请求)用户已经发送了太多的请求在指定的时间里。用于限制速率。

431:(请求头部字段太大)服务器由于一个单独的请求头部字段或者是全部的字段太大而不愿意处理请求。

440:(登陆超时(微软))一个微软的扩展,意味着你的会话已经超时。

444:(无响应)被使用在Nginx的日志中表明服务器没有返回信息给客户端并且关闭了连接(在威慑恶意软件的时候比较有用)。

449:(重试(微软))一个微软的扩展。请求应该在执行适当的动作之后被重试。

450:(被Windows家长控制阻塞(微软))一个微软的扩展。这个错误是当Windows家长控制打开并且阻塞指定网页的访问的时候被指定。

451:(由于法律原因而无效(因特网草稿))被定义在因特网草稿“一个新的HTTP状态码用于法律限制的资源”。被用于当资源的访问由于法律原因被禁止的时候。例如检查制度或者是政府强制要求禁止访问。一个例子是1953年dystopian的小说Fahrenheit 451就是一个非法的资源。

451:(重定向(微软))被用在Exchange ActiveSync中如果一个更有效的服务器能够被使用或者是服务器不能访问用户的邮箱。客户端会假定重新执行HTTP自动发现协议去寻找更适合的服务器。

494:(请求头太大(Nginx))Nginx内置代码和431类似,但是是被更早地引入在版本0.9.4(在2011年1月21日)。

495:(证书错误(Nginx))Nginx内置的代码,当使用SSL客户端证书的时候错误会出现为了在日志错误中区分它和4XX和一个错误页面的重定向。。

496:(没有证书(Nginx))Nginx内置的代码,当客户端不能提供证书在日志中分辨4XX和一个错误页面的重定向。

497:(HTTP到HTTPS(Nginx))Nginx内置的代码,被用于原始的HTTP的请求发送给HTTPS端口去分辨4XX在日志中和一个错误页面的重定向。

498:(令牌超时或失效(Esri))由ArcGIS for Server返回。这个代码意味着令牌的超时或者是失效。

499:(客户端关闭请求(Nginx))被用在Nginx日志去表明一个连接已经被客户端关闭当服务器仍然正在处理它的请求,是的服务器无法返货状态码。

499:(需要令牌(Esri))由ArcGIS for Server返回。意味着需要一个令牌(如果没有令牌被提交)。


5xx:服务器错误

500:(服务器内部错误) 服务器遇到错误,无法完成请求。

501:(尚未实施) 服务器不具备完成请求的功能。 例如,服务器无法识别请求方法时可能会返回此代码。

502:(错误网关) 服务器作为网关或代理,从上游服务器收到无效响应。

503:(服务不可用) 服务器目前无法使用(由于超载或停机维护)。 通常,这只是暂时状态。

504:(网关超时) 服务器作为网关或代理,但是没有及时从上游服务器收到请求。

505:(HTTP 版本不受支持) 服务器不支持请求中所用的 HTTP 协议版本。

506:由《透明内容协商协议》(RFC 2295)扩展,代表服务器存在内部配置错误:被请求的协商变元资源被配置为在透明内容协商中使用自己,因此在一个协商处理中不是一个合适的重点。

507:服务器无法存储完成请求所必须的内容。这个状况被认为是临时的。WebDAV (RFC 4918)

509:服务器达到带宽限制。这不是一个官方的状态码,但是仍被广泛使用。

510:获取资源所需要的策略并没有没满足。(RFC 2774)。

508:(发现环路)服务器发现了一个无限的循环档处理请求的时候。

511:(需要网络授权)客户端需要授权去火的网络的访问权限。一般用于代理交互中被用来进行网络的访问控制。

520:(未知错误)这个状态码也没有被指定在任何RFC中,并且只会被一些服务器返回,例如微软的Azure和CloudFlare服务器:”520错误。本质上是一个捕获全部的响应当原始服务器返回一些未知的或者一些不能被忍受或者被解释的(协议违反或者空响应)”。

598:(网络读取超时异常(未知))这个状态码也没有在任何RFC中指定,但是被用在微软的HTTP代理中去标注一个网络读取超时在一个客户端之前的代理的后面。

599:(网络连接超时异常(未知))这个状态码也没有在任何RFC中指定,但是被用在微软的HTTP代理中去标注一个网络连接超时在一个客户端之前的代理的后面。

如果当前url是 http://localhost:8080/User
那么用户只要请求这样同一个URL就可以实现不同的增删改查操作,例如

http://localhost:8080/User?_method=get&id=1001 这样就可以通过get请求获取到数据库 user 表里面 id=1001 的用户信息
http://localhost:8080/User?_method=post&id=1001&name=zhangsan 这样可以向数据库 user 表里面插入一条记录
http://localhost:8080/User?_method=put&id=1001&name=lisi 这样可以将 user表里面 id=1001 的用户名改为lisi
http://localhost:8080/User?_method=delete&id=1001 这样用于将数据库 user 表里面的id=1001 的信息删除

这样定义的规范我们就可以称之为restful风格的API接口,我们可以通过同一个url来实现各种操作。

二、简介

DRF框架全称是:Django REST framework,它建立在Django基础之上的WEB应用开发框架,基于前后端分离的开发模式,可以快速的开发REST API接口应用;

在REST framework中,提供了序列化器Serialzier的定义,可以帮助我们简化序列化与反序列化的过程,不仅如此,还提供丰富的类视图、扩展类、视图集来简化视图的编写工作。REST framework还提供了认证、权限、限流、过滤、分页、接口文档等功能支持。REST framework提供了一个API 的Web可视化界面来方便查看测试接口。

特点:

  • 提供了定义序列化器Serializer的方法,可以快速根据 Django ORM 或者其它库自动序列化/反序列化;
  • 提供了丰富的类视图、Mixin扩展类,简化视图的编写;
  • 丰富的定制层级:函数视图、类视图、视图集合到自动生成 API,满足各种需要;
  • 多种身份认证和权限认证方式的支持;[jwt]
  • 内置了限流系统;
  • 直观的 API web 界面;
  • 可扩展性,插件丰富

使用DRF框架的优势:
在使用Django写接口代码时,会有很多痛点:

a.代码冗余非常严重,不够简洁
b.数据校验极为麻烦(往往需要嵌套多级if条件语句),校验逻辑的复用性较差
c.代码没有统一的规范,代码维护性较差
d.获取项目列表数据时,有很多功能缺失

  • 没有提供分页功能
  • 没有提供过滤功能
  • 也没有提供排序功能

e.整个项目的痛点

  • 没有提供认证授权功能
  • 没有提供限流功能
  • 传递参数形式单一,只支持json格式的参数,不支持x-www-form-urlencoded
  • 5个接口无法放在同一个类视图中

然而,django restframwork框架解决以上问题

官方文档:Home - Django REST framework

三、安装与配置

安装:

pip install djangorestframework

添加rest_framework应用:
在settings.py的INSTALLED_APPS中添加’rest_framework’。

  1. INSTALLED_APPS = [
  2. ...
  3. 'rest_framework',
  4. ]

四、序列化器

DRF框架中实现序列化、反列化、数据操作;

序列化与反列化的定义:
序列化:如果前端是GET请求,则构造查询集,将结果返回,这个过程为序列化;
反序列化:如果前端是POST请求,要对数据库进行改动,则需要拿到前端发来的数据,进行校验,校验通过将数据写入数据库,这个过程称为反序列化;

1、创建序列化器

在子应用中创建serializers.py文件,文件名推荐命名为serializers.py;

  1. class ProjectSerializer(serializers.Serializer):
  2. # id = serializers.IntegerField(label='项目id', help_text='项目id', max_value=1000, min_value=1)
  3. # name = serializers.CharField(label='项目名称', help_text='项目名称', max_length=20, min_length=5, write_only=True)
  4. name = serializers.CharField(label='项目名称', help_text='项目名称', max_length=20, min_length=5)
  5. # leader = serializers.CharField(label='项目负责人', help_text='项目负责人', allow_null=True)
  6. leader = serializers.CharField(label='项目负责人', help_text='项目负责人', default='阿名')
  7. is_execute = serializers.BooleanField()
  8. # update_time = serializers.DateTimeField()

注意点:
1.必须得继承Serializer类或者Serializer子类
2.定义的序列化器类中,字段名要与模型类中的字段名保持一致;
3.定义的序列化器类的字段(类属性)为Field子类
4.默认定义哪些字段,那么哪些字段就会返回前端,同时也必须的输入(前端需要传递)
5.常用的序列化器字段类型
IntegerField -> int
CharField -> str
BooleanField -> bool
DateTimeField -> datetime
6.可以在序列化器字段中指定不同的选项
label和help_text,与模型类中的verbose_name和help_text参数一样
IntegerField,可以使用max_value指定最大值,min_value指定最小值
CharField,可以使用max_length指定最大长度,min_length指定最小长度,error_messages用来自定义错误信息
7.定义的序列化器字段中,required默认为True,说明默认定义的字段必须得输入和输出
8.如果在序列化器字段中,设置required=False,那么前端用户可以不传递该字段(校验时会忽略改该字段,所以不会报错)
9.如果未定义模型类中的某个字段,那么该字段不会输入,也不会输出
10.前端必须的输入(反序列化输入)name(必须得校验),但是不会需要输出(序列化器输出)?
如果某个参数指定了write_only=True,那么该字段仅仅只输入(反序列化输入,做数据校验),不会输出(序列化器输出),
默认write_only为False
11.前端可以不用传递,但是后端需要输出?
如果某个参数指定了read_only=True,那么该字段仅仅只输出(序列化器输出),不会输入(反序列化输入,做数据校验),
默认read_only为False
12.在序列化器类中定义的字段,默认allow_null=False,该字段不允许传递null空值,如果指定allow_null=True,那么该字段允许传递null;
13.在序列化器类中定义CharField字段,默认allow_blank=False,该字段不允许传递空字符串,如果指定allow_blank=True,那么该字段允许传递空字符串
14.在序列化器类中定义的字段,可以使用default参数来指定默认值,如果指定了default参数,那么前端用户可以不用传递,会将default指定的值作为入参

2、序列化操作

1)序列化过程

get请求(数据查询):数据库操作(读取所有项目数据) -> 序列化输出操作(将模型对象转化为Python中的基本类型),可以使用序列化器进行序列化输出操作:

  • 创建序列化器对象
  • 可以将模型对象或者查询集对象、普通对象、嵌套普通对象的列表,以instance关键字来传递参数(instance关键字可以做序列化输出,而若使用data关键字,则必须要校验,否则报错data keyword argument you must call .is_valid()
  • 如果传递的是查询集对象、嵌套普通对象的列表(多条数据),必须得设置many=True
  • 如果传递的是模型对象、普通对象,不需要设置many=True
  • 可以使用序列化器对象的.data属性,获取序列化器之后的数据(字典、嵌套字典的列表)
  1. def get(self, request):
  2. queryset = Projects.objects.all()
  3. serializer = ProjectSerilizer(instance=queryset, many=True)
  4. return JsonResponse(serializer.data, safe=False)
2)反序列化过程

post请求(数据插入):数据校验(规范传入的参数) —> 反序列化输入操作(将json格式的数据转化为复杂的类型) -> 数据库操作(创建项目数据)-> 序列化输出操作(将模型对象转化为Python中的基本类型):

  • 定义序列化器类,使用data关键字参数传递字典参数
  • 可以使用序列化器对象调用.is_valid()方法,才会开始对前端输入的参数进行校验
  • 如果校验通过.is_valid()方法返回True,否则返回False
  • 如果调用.is_valid()方法,添加raise_exeception=True,校验不通过会抛出异常,否则不会抛出异常
  • 只有在调用.is_valid()方法之后,才可以使用序列化器对象调用.errors属性,来获取错误提示信息(字典类型)
  • 只有在调用.is_valid()方法之后,才可以使用序列化器对象调用.validated_data属性,来获取校验通过之后的数据,与使用json.load转化之后的数据有区别
  1. class ProjectsView(View):
  2. def post(self, request):
  3. try:
  4. python_data = json.loads(request.body)
  5. except Exception as e:
  6. return JsonResponse({'msg': '参数有误'}, status=400)
  7. serializer11 = ProjectSerilizer(data=python_data)
  8. # 校验数据
  9. if not serializer11.is_valid():
  10. return JsonResponse(serializer11.errors, status=400)
  11. # project_obj = Projects.objects.create(**serializer11.validated_data)
  12. serializer11.save()
  13. return JsonResponse(serializer11.data, status=201)

注意:
return JsonResponse(serializer11.data, status=201)serializer11.data这种写法是在两个前提下,否则会报错:

  • 如果没有调用save方法,使用创建序列化器对象.data属性时,必须得调用is_valid()方法通过之后,来获取序列化输出的数据;(会把validated_data数据作为输入源,参照序列化器字段的定义来进行输入)
  • 如果调用了save方法,使用创建序列化器对象.data属性,来获取序列化输出的数据;(会把create方法返回的模型对象数据作为输入源,参照序列化器字段的定义来进行输出)

3、校验规则

反序列化过程会对数据进行校验

1)单表字段校验

校验顺序:对字段类型进行校验 -> 依次验证validators列表中的校验规则 -> 从右到左依次验证其他规则 -> 调用单字段校验方法 -> 调用多字段联合校验方法validate方法

  1. from rest_framework import serializers
  2. from rest_framework.validators import UniqueValidator
  3. from interfaces.models import Interfaces
  4. from .models import Projects
  5. # 类外函数
  6. def is_contains_keyword(value):
  7. if '项目' not in value:
  8. raise serializers.ValidationError('项目名称中必须得包含“项目”关键字')
  9. class ProjectSerilizer(serializers.Serializer):
  10. # 1、对字段类型进行校验
  11. # 2、依次验证validators列表中的校验规则,validators=[UniqueValidator(queryset=Projects.objects.all())]
  12. # 3、从右到左依次验证其他规则 max_length=20, min_length=5...等
  13. name = serializers.CharField(label='项目名称', help_text='项目名称', max_length=20, min_length=5,
  14. error_messages={
  15. 'min_length': '项目名称不能少于5位',
  16. 'max_length': '项目名称不能超过20位'
  17. }, validators=[UniqueValidator(queryset=Projects.objects.all(), message='项目名称不能重复'),
  18. is_contains_keyword])
  19. leader = serializers.CharField(label='项目负责人', help_text='项目负责人', default='阿名')
  20. is_execute = serializers.BooleanField()
  21. # 调用单字段校验方法
  22. # 单字段校验
  23. def validate_name(self, attr: str):
  24. if not attr.endswith('项目'):
  25. raise serializers.ValidationError('项目名称必须得以“项目”结尾')
  26. return attr
  27. # 调用多字段校验方法
  28. # 多字段联合校验
  29. def validate(self, attrs: dict):
  30. if len(attrs.get('leader')) <= 4 or not attrs.get('is_execute'):
  31. raise serializers.ValidationError('项目负责人名称长度不能少于4位或者is_execute参数为False')
  32. return attrs

以上代码为例的校验顺序为:

  1. 字段类型校验:CharField/IntegerFieldBooleanField等Field子类的字段校验;
  2. validators关键字校验,先校验UniqueValidator唯一性,再通过类外自定义的函数is_contains_keyword校验名字中是否包含项目名称1)可以在序列化器字段上使用validators指定自定义的校验规则
    2)validators必须得为序列类型(列表),在列表中可以添加多个校验规则
    3)DRF框架自带UniqueValidator校验器,必须得使用queryset指定查询集对象,用于对该字段进行校验
    4)UniqueValidator校验器,可以使用message指定自定义报错信息
    5)类外自定义校验函数is_contains_keyword,可以在类外自定义校验函数
    • 第一个参数为待校验的值
    • 如果校验不通过,必须得抛出serializers.ValidationError(‘报错信息’)异常,同时可以指定具体的报错信息
    • 需要将校验函数名放置到validators列表中
  1. 从右到左依次验证其他规则,先min_length,再max_length,其中error_messages中为自定义的错误提示信息,error_messages具体用法:1)可以任意序列化器字段上使用error_messages来自定义错误提示信息;
    2)使用校验选项名(校验方法名)作为key,把具体的错误提示信息作为value;
    3)DateTimeField可以使用format参数指定格式化字符串,update_time =serializers.DateTimeField(label=‘更新时间’,format=‘%Y年%m月%d日 %H:%M:%S’)
  2. 然后单字段校验validate_name,单字段校验使用如下:1)可以在序列化器类中对单个字段进行校验;
    2)单字段的校验方法名称,必须把validate_作为前缀,加上待校验的字段名,如:validate_待校验的字段名;
    3)如果校验不通过,必须得返回serializers.ValidationError(‘具体报错信息’)异常;
    4)如果校验通过,往往需要将校验之后的值,返回;
    5)如果该字段在定义时添加的校验规则不通过,那么是不会调用单字段的校验方法;
  3. 多字段联合校验方法validate方法1)可以在序列化器类中对多个字段进行联合校验;
    2)使用固定的validate方法,会接收上面校验通过之后的字典数据;
    3)当所有字段定义时添加的校验规则都通过,且每个字段的单字段校验方法通过的情况下,才会调用validate;
2)关联字段校验

PrimaryKeyRelatedField字段:

  1. # interfaces_set = serializers.PrimaryKeyRelatedField(label='项目所属接口id', help_text='项目所属接口id', many=True, read_only=True)
  2. interfaces_set = serializers.PrimaryKeyRelatedField(label='项目所属接口id', help_text='项目所属接口id',many=True, queryset=Interfaces.objects.all(), write_only=True)
  • 可以定义PrimaryKeyRelatedField来获取关联表的外键值
  • 如果通过父表获取从表数据,默认需要使用从表模型类名小写_set作为序列化器类中的关联字段名称(interfaces_set)
  • 如果在定义模型类的外键字段时,指定了realated_name参数,那么会把realated_name参数名作为序列化器类中的关联字段名称
  • PrimaryKeyRelatedField字段,要么指定read_only=True,要么指定queryset参数,否则会报错
  • 如果指定了read_only=True,那么该字段仅序列化输出
  • 如果指定了queryset参数(关联表的查询集对象),用于对参数进行校验
  • 如果关联字段有多个值,那么必须添加many=True,一般父表获取从表数据时,关联字段需要指定

StringRelatedField字段:

interfaces_set = serializers.StringRelatedField(many=True)
  • 使用StringRelatedField字段,将关联字段模型类中的__str__方法的返回值作为该字段的值
  • StringRelatedField字段默认添加了read_only=True,该字段仅序列化输出

SlugRelatedField字段:

interfaces_set = serializers.SlugRelatedField(slug_field='name', many=True, queryset=Interfaces.objects.all())
  • 使用SlugRelatedField字段,将关联模型类中的某个字段,作为该字段的值
  • 如果指定了read_only=True,那么该字段仅序列化输出
  • 如果该字段需要进行反序列化输入,那么必须得指定queryset参数,同时关联字段必须有唯一约束

4、优化serializer.save()

创建数据create

  1. # views.py
  2. serializer11 = ProjectSerilizer(data=python_data)
  3. serializer11.save()
  4. # 调用save方法时会自动调用serializers.py中的create方法
  5. #---分隔线----
  6. # serializers.py
  7. class ProjectSerializer(serializers.Serializer):
  8. name = serializers.CharField(label='项目名称', help_text='项目名称', max_length=20, min_length=5,
  9. error_messages={"min_length": "最短不能少于5位"},
  10. validators=[UniqueValidator(queryset=Projects.objects.all(), message="项目名称不能重复"),
  11. is_contains_keyword])
  12. leader = serializers.CharField(label='项目负责人', help_text='项目负责人')
  13. is_execute = serializers.BooleanField(write_only=True)
  14. def create(self, validated_data):
  15. myname = validated_data.pop('myname')
  16. myage = validated_data.pop('myage')
  17. validated_data.pop('sms_code')
  18. project_obj = Projects.objects.create(**validated_data)
  19. return project_obj
  • 如果在创建序列化器对象时,仅传递data参数,使用序列化器对象调用save方法时,会自动调用序列化器类中的create方法
  • create方法用于对数据进行创建操作
  • 序列化器类中的create方法,validated_data参数为校验通过之后的数据(一般字典类型)
  • 在调用save方法时,可以传递任意的关键字参数,并且会自动合并到validated_data字典中
  • create方法一般需要将创建成功之后模型对象返回

更新数据update

  1. def put(self, request, pk):
  2. try:
  3. project_obj = Projects.objects.get(id=pk)
  4. python_data = json.loads(request.body)
  5. except Exception as e:
  6. return JsonResponse({'msg': '参数有误'}, status=400)
  7. serializer = ProjectSerilizer(instance=project_obj, data=python_data)
  8. if not serializer.is_valid():
  9. return JsonResponse(serializer.errors, status=400)
  10. serializer.save()
  11. return JsonResponse(serializer.data, status=201)
  1. def update(self, instance, validated_data: dict):
  2. # for key, value in validated_data.items():
  3. # setattr(instance, key, value)
  4. instance.name = validated_data.get('name') or instance.name
  5. instance.leader = validated_data.get('leader') or instance.leader
  6. instance.is_execute = validated_data.get('is_execute') or instance.is_execute
  7. instance.desc = validated_data.get('desc') or instance.desc
  8. instance.save()
  9. return instance
  • 如果在创建序列化器对象时,同时instance和data参数,使用序列化器对象调用save方法时,会自动调用序列化器类中的update方法
  • update方法用于对数据进行更新操作
  • 序列化器类中的update方法,instance参数为待更新的模型对象,validated_data参数为校验通过之后的数据(一般字典类型)
  • 在调用save方法时,可以传递任意的关键字参数,并且会自动合并到validated_data字典中
  • update方法一般需要将更新成功之后模型对象返回

5、to_internal_value

允许改变我们反序列化的输出,处理反序列化的输入数据

  1. class ProjectSerilizer(serializers.Serializer):
  2. def to_internal_value(self, data):
  3. # 1to_internal_value方法,是所有字段开始进行校验时入口方法(最先调用的方法)
  4. # 2、会依次对序列化器类的各个序列化器字段进行校验:
  5. # 对字段类型进行校验 -> 依次验证validators列表中的校验规则 -> 从右到左依次验证其他规则 -> 调用单字段校验方法
  6. # to_internal_value调用结束 -> 调用多字段联合校验方法validate方法
  7. tmp = super().to_internal_value(data)
  8. # 对各个单字段校验结束之后的数据进行修改
  9. return tmp

6、to_representation

允许我们改变序列化的输出;

  1. class ProjectSerilizer(serializers.Serializer):
  2. def to_representation(self, instance):
  3. # 1to_representation方法,是所有字段开始进行序列化输出时的入口方法(最先调用的方法)
  4. tmp =super().to_representation(instance)
  5. return tmp

五、模型序列化器类

模型类序列化器ModelSerilizer,跟表模型有对应关系

1、定义模型序列化器类

  1. class ProjectModelSerializer(serializers.ModelSerializer):
  2. """
  3. 定义模型序列化器类
  4. 1、继承serializers.ModelSerializer类或者其子类
  5. 2、需要在Meta内部类中指定model、fields、exclude类属性参数
  6. 3、model指定模型类(需要生成序列化器的模型类)
  7. 4、fields指定模型类中哪些字段需要自动生成序列化器字段
  8. 5、会给id主键、指定了auto_now_add或者auto_now参数的DateTimeField字段,添加read_only=True,仅仅只进行序列化输出
  9. 6、有设置unique=True的模型字段,会自动在validators列表中添加唯一约束校验<UniqueValidator
  10. 7、有设置default=True的模型字段,会自动添加required=False
  11. 8、有设置null=True的模型字段,会自动添加allow_null=True
  12. 9、有设置blank=True的模型字段,会自动添加allow_blank=True
  13. """
  14. class Meta:
  15. model = Projects
  16. # fields指定模型类中哪些字段需要自动生成序列化器字段
  17. # a.如果指定为"__all__",那么模型类中所有的字段都需要自动转化为序列化器字段
  18. # b.可以传递需要转化为序列化器字段的模型字段名元组
  19. # c.fields元组中必须指定进行序列化或者反序列化操作的所有字段名称,指定了'__all__'和exclude除外
  20. fields = "__all__"
  21. # fields = ('id', 'name', 'leader')
  22. # c.exclude指定模型类中哪些字段不需要转化为序列化器字段,其他的字段都需要转化
  23. # exclude = ('create_time', 'update_time')

tips:主动查看生成的字段方法:然后到terminal下执行 python manage.py shell,然后执行from projects.serializers import ProjectsModelSerializer,然后执行ProjectsModelSerializer();

2、修改部分字段方法

方式一:

  • 重新定义模型类中同名的字段
  • 自定义字段的优先级会更高(会覆盖自动生成的序列化器字段);
  1. # 重新定义模型类中同名的字段
  2. name = serializers.CharField(label='项目名称', help_text='项目名称', max_length=20, min_length=5,error_messages={'min_length': '项目名称不能少于5位','max_length': '项目名称不能超过20位'}, validators=[UniqueValidator(queryset=Projects.objects.all(),message='项目名称不能重复'), is_contains_keyword])
  3. interfaces_set = serializers.PrimaryKeyRelatedField(many=True, read_only=True)
  4. # 新定义的字段,只做序列化输出,输入时不会校验;
  5. token = serializers.CharField(read_only=True)

方式二:

  • 如果自动生成的序列化器字段,只有少量不满足要求,可以在Meta中extra_kwargs字典进行微调
  • 将需要调整的字段作为key,把具体需要修改的内容字典作为value
  1. # 重新定义模型类中同名的字段
  2. name = serializers.CharField(label='项目名称', help_text='项目名称', max_length=20, min_length=5,error_messages={'min_length': '项目名称不能少于5位','max_length': '项目名称不能超过20位'}, validators=[UniqueValidator(queryset=Projects.objects.all(),message='项目名称不能重复'), is_contains_keyword])
  3. interfaces_set = serializers.PrimaryKeyRelatedField(many=True, read_only=True)
  4. # 新定义的字段,只做序列化输出,输入时不会校验;
  5. token = serializers.CharField(read_only=True)
  6. extra_kwargs = {
  7. 'leader': {
  8. 'label': '负责人',
  9. 'max_length': 15,
  10. 'min_length': 2,
  11. # 'read_only': True
  12. # 'validators': []},
  13. 'name': {'min_length': 5}}
  14. # 可以将需要批量需要设置read_only=True参数的字段名添加到Meta中read_only_fields元组
  15. read_only_fields = ('leader', 'is_execute', 'id')

3、模型器类重写creat/update

  1. def create(self, validated_data):
  2. """
  3. a.继承ModelSerializer之后,ModelSerializer中实现了create和update方法
  4. b.一般无需再次定义create和update方法
  5. c.如果父类提供的create和update方法不满足需要时,可以重写create和update方法,最后再调用父类的create和update方法
  6. :param validated_data:
  7. :return:
  8. """
  9. validated_data.pop('myname')
  10. validated_data.pop('myage')
  11. instance = super().create(validated_data)
  12. instance.token = "xxxxxxx"
  13. return instance

六、视图层views

1、APIView渲染器

  1. class ProjectsView(APIView):
  2. """
  3. 继承APIView父类(Django中View的子类)
  4. a.具备View的所有特性
  5. b.提供了认证、授权、限流功能
  6. """
  7. def get(self, request):
  8. queryset = Projects.objects.all()
  9. serializer = ProjectSerilizer(instance=queryset, many=True)
  10. # 在DRF中Response为HTTPResponse的子类
  11. # a.data参数为序列化之后的数据(一般为字典或嵌套字典的列表)
  12. # b.会自动根据渲染器来将数据转化为请求头中Accept需要的格式进行返回
  13. # c.status指定响应状态码
  14. # d.content_type指定响应头中的Content-Type,一般无需指定,会根据渲染器来自动设置
  15. return Response(serializer.data, status=status.HTTP_200_OK, content_type='ap')
  16. def post(self, request):
  17. # a.一旦继承APIView之后,request是DRF中Request对象
  18. # b.Request是在HttpRequest基础上做了拓展
  19. # c.兼容HttpRequest的所有功能
  20. # d.前端传递的查询字符串参数:GET、query_params
  21. # e.前端传递application/json、application/x-www-form-urlencoded、multipart/form-data参数
  22. # 可以根据请求头中Content-Type,使用统一的data属性获取
  23. # try:
  24. # python_data = json.loads(request.body)
  25. # except Exception as e:
  26. # return JsonResponse({'msg': '参数有误'}, status=400)
  27. # python_data = request.data
  28. serializer = ProjectModelSerializer(data=request.data)
  29. # if not serializer.is_valid():
  30. # # return JsonResponse(serializer11.errors, status=400)
  31. # return Response(serializer.errors, status=400)
  32. serializer.is_valid(raise_exception=True)
  33. serializer.save()
  34. return Response(serializer.data, status=status.HTTP_201_CREATED)

2、解析器

parsers=self.get_parsers()就是解析模块源码的入口
解析器和渲染器类的修改

  1. # DRF中的解析器(类)
  2. # 1、可以根据请求头中的Content-Type来自动解析参数,使用统一的data属性来获取即可
  3. # 2、默认JSONParser、FormParser、MultiPartParser三个解析器类
  4. # JSONParser:media_type = 'application/json'
  5. # FormParser:media_type = 'application/x-www-form-urlencoded'
  6. # MultiPartParser: media_type = 'multipart/form-data'
  7. # 3、可以在全局配置文件(settings.py)中修改DRF全局参数,把REST_FRAMEWORK作为名称
  8. REST_FRAMEWORK = {
  9. 'DEFAULT_PARSER_CLASSES': [
  10. 'rest_framework.parsers.JSONParser',
  11. # 'rest_framework.parsers.FormParser',
  12. # 'rest_framework.parsers.MultiPartParser'
  13. ],
  14. # 4、局部配置
  15. # 默认全局配置是因为我们写的视图继承自APIView,APIView中配置了类属性parser_classes,所以我们自己编写的视图函数中,也设置个类属性,并且导入JSONParser解析器
  16. from rest_framework.parsers import JSONParser
  17. class TestView(APIView):
  18. # 局部解析类配置,只加JSONParser配置后,就只能application/json提交数据,其他方式会报错
  19. parser_classes = [JSONParser]
  20. def post(self, request, *args, **kwargs):
  21. print(request.data)
  22. return Response("drf post ok")

3、渲染器

  1. # DRF中的渲染器(类)
  2. # 1、可以根据请求头中的Accept参数来自动渲染前端需要的数据格式
  3. # 2、默认的渲染器为JSONRenderer、BrowsableAPIRenderer
  4. # 3、如果前端请求头未指定Accept参数或者指定为application/json,那么会自动返回json格式的数据
  5. # 4、如果前端请求头指定Accept参数为text/html,那么默认会返回可浏览的api页面(api进行管理)
  6. # 5、可以在DEFAULT_RENDERER_CLASSES中指定需要使用的渲染器
  7. 'DEFAULT_RENDERER_CLASSES': [
  8. 'rest_framework.renderers.JSONRenderer',
  9. # 'rest_framework.renderers.BrowsableAPIRenderer',
  10. ],
  11. }

4、GenericAPIView

继承自APIVIew,增加了对于列表视图和详情视图可能用到的通用支持方法。通常使用时,可搭配一个或多个Mixin扩展类。
注意:查询结果集是会被缓存的,相当于,当我们执行模型类.objects.all()后,数据会放到缓存中

1)queryset和serializer_class

GenericAPIView提供了两个类属性,queryset(指定查询集)和serializer_class(指定序列化器类)

  • queryset指定当前类视图的实例方法需要使用的查询集对象
  • serializer_class指定当前类视图的实例方法需要使用的序列化器类
    然后通过self.get_queryset()和self.get_serializer方法分别去获取
  1. # 需继承GenericAPIView
  2. #class ProjectViews(APIView):
  3. class ProjectViews(GenericAPIView):
  4. queryset = Projects.objects.all()
  5. serializer_class = serializers.ProjectModelSerializer
  6. def get(self, request: Request):
  7. ...
  8. # 一般不用self.queryset获取,而使用self.get_queryset获取类属性queryset
  9. queryset = self.get_queryset()
  10. # 同上,使用self.get_serializer获取类属性serializer_class
  11. self.get_serializer(instance=queryset)
2)get_object

get_object可以获取模型对象,无需传递外键值,会自动获取url中传入的pk值(若自定义名字,则需指定lookup_field=‘ww’,那么url中的变量也要是ww,如‘projects/int:ww’)
project_obj = self.get_object()
源码如下:

  1. def get_object(self):
  2. """
  3. Returns the object the view is displaying.
  4. You may want to override this if you need to provide non-standard
  5. queryset lookups. Eg if objects are referenced using multiple
  6. keyword arguments in the url conf.
  7. """
  8. queryset = self.filter_queryset(self.get_queryset())
  9. # Perform the lookup filtering.
  10. ########此处lookup_url_kwarg为url传过来的pk
  11. lookup_url_kwarg = self.lookup_url_kwarg or self.lookup_field
  12. assert lookup_url_kwarg in self.kwargs, (
  13. 'Expected view %s to be called with a URL keyword argument '
  14. 'named "%s". Fix your URL conf, or set the `.lookup_field` '
  15. 'attribute on the view correctly.' %
  16. (self.__class__.__name__, lookup_url_kwarg)
  17. )
  18. filter_kwargs = {self.lookup_field: self.kwargs[lookup_url_kwarg]}
  19. obj = get_object_or_404(queryset, **filter_kwargs)
  20. # May raise a permission denied
  21. self.check_object_permissions(self.request, obj)
  22. return obj
3)过滤

a、指定过滤器

第一种方式:全局指定
在django的settings设置以下过滤引擎类,在全局DEFAULT_FILTER_BACKENDS指定使用的过滤引擎类(SearchFilter为搜索引擎类)

  1. REST_FRAMEWORK = { 'DEFAULT_FILTER_BACKENDS': [
  2. 'rest_framework.filters.SearchFilter',
  3. 'rest_framework.filters.OrderingFilter']}

第二种方式:在视图中指定

  1. from rest_framework.filters import SearchFilter
  2. class ProjectViews(GenericAPIView):
  3. ...
  4. filter_backends = [SearchFilter]
  • views中的模型类里面,类属性中罗列出搜索的字段
  • search_fields = [‘^name’, ‘=leader’, ‘id’]
  • 在字段前面添加前缀指定过滤方法。
    • 默认的过滤方法为icontain(忽略大小写的包含查询)
    • 字段前加’^'为 ‘istartswith’(以…开头)
    • 字段前加’='为 ‘iexact’(忽略大小写的相等)
    • 字段前加’$'为 ‘iregex’(忽略大小写的正则)
      在方法中使用self.filter_queryset(self.get_queryset())获取过滤后的查询集,此时,前端传query string参数?search=xxx就可以使用过滤功能了
  1. class ProjectViews(GenericAPIView):
  2. queryset = Projects.objects.all()
  3. serializer_class = serializers.ProjectModelSerializer
  4. search_fields = ['^name', '=leader']
  5. def get(self, request: Request):
  6. # filter_queryset需要传递查询集对象作为参数
  7. queryset = self.filter_queryset(self.get_queryset())
  8. serializer = self.get_serializer(instance=queryset, many=True)
  9. return Response(serializer.data, status=status.HTTP_200_OK)

b、修改参数
注意:http://127.0.0.1:8000/projects/?search=dj,必须用search,如果制定别的关键字需在settings中指定SEARCH_PARAM=‘s’
现在我们修改query string参数的默认key“search”

  1. REST_FRAMEWORK = {
  2. ...
  3. 'SEARCH_PARAM': 's',
  4. }

此时,前端需要传query string参数?s=xxx才能使用过滤功能ordering_fields = [‘id’, ‘-name’, ‘leader’]

4)排序

a、指定过滤器

第一种方式:全局指定

  1. REST_FRAMEWORK = {
  2. ...
  3. 'DEFAULT_FILTER_BACKENDS': ['rest_framework.filters.OrderingFilter'],
  4. }

第二种方式:在视图中指定

  1. from rest_framework.filters import OrderingFilter
  2. class ProjectViews(GenericAPIView):
  3. ...
  4. queryset = Projects.objects.all()
  5. serializer_class = serializers.ProjectModelSerializer
  6. filter_backends = [OrderingFilter]
  7. # 指定需要过滤的字段
  8. ordering_fields = ['id', 'name', 'leader']
  9. # 指定默认排序字段
  10. ordering = ['name']
  11. ...

前端传query string参数:http://127.0.0.1:8000/projects/?ordering=-name,id,就可以使用过滤功能了(默认生序,若降序在字段前加-号,如果指定多个排序字段,使用英文逗号进行分割)。

b、修改参数
修改query string参数的默认key“ordering”

  1. REST_FRAMEWORK = {
  2. ...
  3. 'ORDERING_PARAM': 'o',
  4. }

此时,前端需要传query string参数?o=xxx才能使用过滤功能。

4)分页

a、直接引用PageNumberPagination
引用DRF框架自带的类rest_framework.pagination.PageNumberPagination

  1. # settings.py
  2. REST_FRAMEWORK = {
  3. 'DEFAULT_PAGINATION_CLASS': 'rest_framework.pagination.PageNumberPagination',
  4. }

b、自定义PageNumberPagination类
自定义PageNumberPagination类,然后在settings.py的配置中修改

  1. # settings.py
  2. REST_FRAMEWORK = {
  3. # 'DEFAULT_PAGINATION_CLASS': 'rest_framework.pagination.PageNumberPagination',
  4. 'DEFAULT_PAGINATION_CLASS': 'utils.pagination.PageNumberPagination',
  5. }
  1. # utils/pagination.py
  2. from rest_framework.pagination import PageNumberPagination as _PageNumberPagination
  3. # 导入DRF中的PageNumberPagination类时重命名为_PageNumberPagination
  4. class PageNumberPagination(_PageNumberPagination):
  5. # 指定默认每一页显示3条数据
  6. page_size = 3
  7. # 前端用于指定页码的查询字符串参数名称
  8. page_query_param = 'pp'
  9. # 前端用于指定页码的查询字符串参数描述
  10. page_query_description = '获取的页码'
  11. # 前端用于指定每一页显示的数据条数,查询字符串参数名称
  12. page_size_query_param = 'ss'
  13. page_size_query_description = '每一页数据条数'
  14. # 当接口uri中传入的size大于当前设置的max_page_size,则按max_page_size中的数据返回数据个数
  15. max_page_size = 50
  16. invalid_page_message = '无效页码'
  17. # 重写父类的方法给返回的数据增加页号字段
  18. def get_paginated_response(self, data):
  19. # 调用父类的实现
  20. response = super().get_paginated_response(data)
  21. # 增加页号字段
  22. response.data['current_num'] = self.page.number
  23. response.data['max_num'] = self.page.paginator.num_pages
  24. # 返回新增后的字典
  25. return response

c、应用
views.py,修改视图类添加分页功能

  1. class ProjectViews(GenericAPIView):
  2. queryset = Projects.objects.all()
  3. serializer_class = serializers.ProjectModelSerializer
  4. filter_backends = [SearchFilter, OrderingFilter]
  5. search_fields = ['^name', '=leader']
  6. def get(self, request: Request):
  7. queryset = self.filter_queryset(self.get_queryset())
  8. # 使用paginate_queryset方法,进行分页操作;需要接收查询集参数;如果返回的数据为空,说明不进行分页操作,否则需要进行分页操作
  9. page = self.paginate_queryset(queryset)
  10. if page is not None:
  11. # 调用get_serializer,将page作为参数传给instance
  12. serializer = self.get_serializer(instance=page, many=True)
  13. # 分页必须调用get_paginated_response方法返回
  14. return self.get_paginated_response(serializer.data)
  15. serializer = self.get_serializer(instance=queryset, many=True)
  16. return Response(serializer.data, status=status.HTTP_200_OK)
4)总结

GenericAPIView主要的属性:

  • queryset: 指定查询集,如:queryset = Projects.objects.all()
  • serializer_class: 指定序列化器类,如:serializer_class = serializers.ProjectModelSerializer

GenericAPIView主要的方法

  • get_queryset(): 获取类属性中指定的查询集。
  • get_serializer(): 获取类属性中指定的序列化器类。
  • get_serializer_class(): 返回序列化器类,调用get_serializer()时会调用这个方法,默认返回serializer_class。
  • filter_queryset(): 使用过滤器对数据进行过滤,需要接收查询集参数。
  • paginate_queryset(): 对传入的数据进行分页操作,需要接收查询集参数。
  • get_paginated_response(): 为给定的输出数据返回一个分页样式的’ Response '对象,一般传参为serializer.data。
  • get_object():根据pk获取单个数据。
  1. class ProjectsView(GenericAPIView):
  2. """
  3. 继承GenericAPIView父类(GenericAPIView子类)
  4. a.具备View的所有特性
  5. b.具备了APIView中的认证、授权、限流功能
  6. c.还支持对于获取列表数据接口的功能:搜索、排序、分页
  7. """
  8. # 一旦继承GenericAPIView之后,往往需要指定queryset、serializer_class类属性
  9. # queryset指定当前类视图的实例方法需要使用的查询集对象
  10. queryset = Projects.objects.all()
  11. # serializer_class指定当前类视图的实例方法需要使用的序列化器类
  12. serializer_class = ProjectSerilizer
  13. # 可以在类视图中指定分页引擎类,优先级高于全局
  14. pagination_class = PageNumberPagination
  15. # filter_backends在继承了GenericAPIView的类视图中指定使用的过滤引擎类(搜索、排序)
  16. # 优先级高于全局
  17. filter_backends = [filters.SearchFilter, filters.OrderingFilter]
  18. # 2、在继承了GenericAPIView的类视图中,search_fields类属性指定模型类中需要进行搜索过滤的字段名
  19. # 3、使用icontains查询类型作为过滤类型
  20. # 4、可以在字段名称前添加相应符号,指定查询类型
  21. # '^': 'istartswith',
  22. # '=': 'iexact',
  23. # '$': 'iregex',
  24. search_fields = ['^name', '=leader', 'id']
  25. # ordering_fields类属性指定模型类中允许前端进行排序的字段名称
  26. # 前端默认可以使用ordering作为排序功能查询字符串参数名称,默认改字段的升序
  27. # 如果在字段名称前添加“-”,代表改字段降序
  28. # 如果指定多个排序字段,使用英文逗号进行分割
  29. ordering_fields = ['id', 'name', 'leader']
  30. def get(self, request: Request):
  31. # name_param = request.query_params.get('name')
  32. # if name_param:
  33. # queryset = Projects.objects.filter(name__exact=name_param)
  34. # else:
  35. # queryset = Projects.objects.all()
  36. # queryset = Projects.objects.all()
  37. # 1、在实例方法中,往往使用get_queryset()方法获取查询集对象
  38. # 2、一般不会直接调用queryset类属性,原因:为了提供让用户重写get_queryset()
  39. # 3、如果未重写get_queryset()方法,那么必须得指定queryset类属性
  40. # 4、调用self.get_queryset()方法时,类属性必须要有queryset类属性
  41. # queryset = self.queryset
  42. # queryset = self.get_queryset()
  43. # filter_queryset对查询对象进行过滤操作
  44. queryset = self.filter_queryset(self.get_queryset())
  45. # serializer = ProjectSerilizer(instance=queryset, many=True)
  46. # 调用paginate_queryset方法对查询集对象进行分页
  47. page = self.paginate_queryset(queryset)
  48. if page is not None:
  49. serializer = self.get_serializer(instance=page, many=True)
  50. return self.get_paginated_response(serializer.data)
  51. # 1、在实例方法中,往往使用get_serializer()方法获取序列化器类
  52. # 2、一般不会直接调用serializer_class类属性,原因:为了让用户重写get_serializer_class()
  53. # 3、如果未重写get_serializer_class()方法,那么必须得指定serializer_class类属性
  54. # 4、调用self.get_serializer()方法时,类属性必须要有serializer_class类属性
  55. # serializer = self.serializer_class(instance=queryset, many=True)
  56. serializer = self.get_serializer(instance=queryset, many=True)
  57. return Response(serializer.data, status=status.HTTP_200_OK)
  58. def post(self, request):
  59. # serializer = ProjectModelSerializer(data=request.data)
  60. # serializer = self.serializer_class(data=request.data)
  61. serializer = self.get_serializer(data=request.data)
  62. serializer.is_valid(raise_exception=True)
  63. serializer.save()
  64. return Response(serializer.data, status=status.HTTP_201_CREATED)

5、Mixin拓展类

Mixin拓展类,拓展类只提供了action方法(mixins库下的各个类);

action方法:
list --> 获取列表数据(ListModelMixin类的list方法)
retrieve --> 获取详情数据(RetrieveModelMixin类的retrieve方法)
create --> 创建数据(CreateModelMixin类的create方法)
update --> 更新数据(完整)(UpdateModelMIxin类的update方法)
partial_update --> 更新数据(部分)(UpdateModelMIxin类的update方法)
destroy --> 删除数据(DestroyModelMixin类的destroy方法)

1)ListModelMixin

列表视图扩展类,提供list(request, *args, **kwargs)方法快速实现列表视图,返回200状态码。
该Mixin的list方法会对数据进行过滤和分页。

源码如下:

  1. # 源码:
  2. class ListModelMixin(object):
  3. """
  4. List a queryset.
  5. """
  6. def list(self, request, *args, **kwargs):
  7. queryset = self.filter_queryset(self.get_queryset())
  8. page = self.paginate_queryset(queryset)
  9. if page is not None:
  10. serializer = self.get_serializer(page, many=True)
  11. return self.get_paginated_response(serializer.data)
  12. serializer = self.get_serializer(queryset, many=True)
  13. return Response(serializer.data)

实际使用:

  1. from rest_framework.generics import GenericAPIView
  2. from rest_framework.mixins import ListModelMixin
  3. from book.models import BookInfo
  4. from book.serializers import BookInfoModelSerializer
  5. class BookListGenericMixinView(ListModelMixin,GenericAPIView):
  6. # 设置查询结果集属性
  7. queryset = BookInfo.objects.all()
  8. # 设置序列化器属性
  9. serializer_class = BookInfoModelSerializer
  10. def get(self,request):
  11. #调用Mixin抽取好的list方法
  12. return self.list(request)
  13. # ------------分割线-------------------------------------------
  14. # 上述BookListGenericMixinView引用的父类可以合并使用ListAPIView替换
  15. from rest_framework.generics import ListAPIView
  16. class BookListGenericMixinView(ListAPIView):
  17. queryset = BookInfo.objects.all()
  18. serializer_class = BookInfoModelSerializer
  19. # ------------分割线-------------------------------------------
  20. # 我们来看下ListAPIView的源码,就知道为啥可以替换了
  21. # ListAPIView源码如下:
  22. class ListAPIView(mixins.ListModelMixin,
  23. GenericAPIView):
  24. def get(self, request, *args, **kwargs):
  25. return self.list(request, *args, **kwargs)
2)CreateModelMixin

创建视图扩展类,提供create(request, *args, **kwargs)方法快速实现创建资源的视图,成功返回201状态码。
如果序列化器对前端发送的数据验证失败,返回400错误。

源码:

  1. # 源码
  2. class CreateModelMixin(object):
  3. """
  4. Create a model instance.
  5. """
  6. def create(self, request, *args, **kwargs):
  7. serializer = self.get_serializer(data=request.data)
  8. serializer.is_valid(raise_exception=True)
  9. self.perform_create(serializer)
  10. headers = self.get_success_headers(serializer.data)
  11. return Response(serializer.data, status=status.HTTP_201_CREATED, headers=headers)
  12. def perform_create(self, serializer):
  13. serializer.save()
  14. def get_success_headers(self, data):
  15. try:
  16. return {'Location': str(data[api_settings.URL_FIELD_NAME])}
  17. except (TypeError, KeyError):
  18. return {}

具体使用:

  1. from rest_framework.generics import GenericAPIView
  2. from rest_framework.mixins import CreateModelMixin
  3. from book.models import BookInfo
  4. from book.serializers import BookInfoModelSerializer
  5. class BookListGenericMixinView(CreateModelMixin,GenericAPIView):
  6. # 设置查询结果集属性
  7. queryset = BookInfo.objects.all()
  8. # 设置序列化器属性
  9. serializer_class = BookInfoModelSerializer
  10. def post(self,request):
  11. # 调用Mixin抽取好create的方法
  12. return self.create(request
3)RetrieveModelMixin

详情视图扩展类,提供retrieve(request, *args, **kwargs)方法,可以快速实现返回一个存在的数据对象。
如果存在,返回200, 否则返回404。

源码:

  1. class RetrieveModelMixin(object):
  2. """
  3. Retrieve a model instance.
  4. """
  5. def retrieve(self, request, *args, **kwargs):
  6. instance = self.get_object()
  7. serializer = self.get_serializer(instance)
  8. return Response(serializer.data)

具体使用:

  1. from rest_framework.generics import GenericAPIView
  2. from rest_framework.mixins import RetrieveModelMixin,UpdateModelMixin,DestroyModelMixin
  3. from book.models import BookInfo
  4. from book.serializers import BookInfoModelSerializer
  5. class BookDetailGenericMixinView(RetrieveModelMixin, GenericAPIView):
  6. # 设置查询结果集属性
  7. queryset = BookInfo.objects.all()
  8. # 设置序列化器属性
  9. serializer_class = BookInfoModelSerializer
  10. def get(self, request,pk):
  11. # 调用Mixin抽取好的retrieve方法
  12. return self.retrieve(request)
4)UpdateModelMixin

更新视图扩展类,提供update(request, *args, **kwargs)方法,可以快速实现更新一个存在的数据对象。
同时也提供partial_update(request, *args, **kwargs)方法,可以实现局部更新。
成功返回200,序列化器校验数据失败时,返回400错误。
源码:

  1. class UpdateModelMixin(object):
  2. """
  3. Update a model instance.
  4. """
  5. def update(self, request, *args, **kwargs):
  6. partial = kwargs.pop('partial', False)
  7. instance = self.get_object()
  8. serializer = self.get_serializer(instance, data=request.data, partial=partial)
  9. serializer.is_valid(raise_exception=True)
  10. self.perform_update(serializer)
  11. if getattr(instance, '_prefetched_objects_cache', None):
  12. # If 'prefetch_related' has been applied to a queryset, we need to
  13. # forcibly invalidate the prefetch cache on the instance.
  14. instance._prefetched_objects_cache = {}
  15. return Response(serializer.data)
  16. def perform_update(self, serializer):
  17. serializer.save()
  18. def partial_update(self, request, *args, **kwargs):
  19. kwargs['partial'] = True
  20. return self.update(request, *args, **kwargs)

具体使用:

  1. from rest_framework.generics import GenericAPIView
  2. from rest_framework.mixins import UpdateModelMixin
  3. from book.models import BookInfo
  4. from book.serializers import BookInfoModelSerializer
  5. class BookDetailGenericMixinView(UpdateModelMixin, GenericAPIView):
  6. # 设置查询结果集属性
  7. queryset = BookInfo.objects.all()
  8. # 设置序列化器属性
  9. serializer_class = BookInfoModelSerializer
  10. def put(self, request,pk):
  11. # 调用Mixin抽取好update的方法
  12. return self.update(request)
5)DestroyModelMixin

删除视图扩展类,提供destroy(request, *args, **kwargs)方法,可以快速实现删除一个存在的数据对象。
成功返回204,不存在返回404。
源码:

  1. class DestroyModelMixin(object):
  2. """
  3. Destroy a model instance.
  4. """
  5. def destroy(self, request, *args, **kwargs):
  6. instance = self.get_object()
  7. self.perform_destroy(instance)
  8. return Response(status=status.HTTP_204_NO_CONTENT)
  9. def perform_destroy(self, instance):
  10. instance.delete()

具体使用:

  1. from rest_framework.generics import GenericAPIView
  2. from rest_framework.mixins import DestroyModelMixin
  3. from book.models import BookInfo
  4. from book.serializers import BookInfoModelSerializer
  5. class BookDetailGenericMixinView(DestroyModelMixin, GenericAPIView):
  6. # 设置查询结果集属性
  7. queryset = BookInfo.objects.all()
  8. # 设置序列化器属性
  9. serializer_class = BookInfoModelSerializer
  10. def delete(self,request,pk):
  11. 调用Mixin抽取好destory的方法
  12. return self.destroy(request)

6、类视图

类视图将Mixin拓展类和GenericAPIView结合,比如generics.ListAPIView直接继承Mixin拓展类((只提供了action方法))和GenericAPIView类,而generics.ListAPIView中将方法与action连接起来,如下:

  1. class ListAPIView(mixins.ListModelMixin,
  2. GenericAPIView):
  3. def get(self, request, *args, **kwargs):
  4. return self.list(request, *args, **kwargs)

类视图识别action方法对应情况如下(generics库下的各个类):

get --> list (ListAPIView类下的get方法)
get --> retrieve (RetrivevAPIView类下的get方法)
post --> create (CreateAPIView下的post方法)
put --> update (UpdateAPIView类下的put方法)
patch --> partial_update (UpdateAPIView类下的patch方法)
delete --> destroy (DestroyAPIView类下的delete方法)
除此之外还有ListCreateAPIView、RetrivevUpdateAPIView、RetrivevDestroyAPIView、RetrivevUpdateDestroyAPIView方法,具体可以查看源码

ListAPIView ====〉mixins.ListModelMixin, GenericAPIView
CreateAPIView ==== 〉mixins.CreateModelMixin, GenericAPIView
RetrieveAPIView==== 〉mixins.RetrieveModelMixin, GenericAPIView
DestroyAPIView ====〉mixins.DestroyModelMixin, GenericAPIView
UpdateAPIView ====〉mixins.UpdateModelMixin, GenericAPIView
ListCreateAPIView ==== 〉mixins.ListModelMixin,mixins.CreateModelMixin, GenericAPIView
RetrieveUpdateAPIView ====〉mixins.RetrieveModelMixin, mixins.UpdateModelMixin, GenericAPIView
RetrieveDestroyAPIView ====〉mixins.RetrieveModelMixin, mixins.DestroyModelMixin, GenericAPIView
RetrieveUpdateDestroyAPIView ====〉mixins.RetrieveModelMixin, mixins.UpdateModelMixin, mixins.DestroyModelMixin, GenericAPIView

  1. # class ProjectsDetailView(
  2. # mixins.RetrieveModelMixin,
  3. # mixins.UpdateModelMixin,
  4. # mixins.DestroyModelMixin,
  5. # GenericAPIView):
  6. # 为了进一步优化代码,需要使用具体的通用视图XXXAPIView
  7. class ProjectsDetailView(generics.RetrieveUpdateDestroyAPIView):
  8. queryset = Projects.objects.all()
  9. serializer_class = ProjectSerilizer

genaric.py源码

  1. class CreateAPIView(mixins.CreateModelMixin,
  2. GenericAPIView):
  3. """
  4. Concrete view for creating a model instance.
  5. """
  6. def post(self, request, *args, **kwargs):
  7. return self.create(request, *args, **kwargs)
  8. class ListAPIView(mixins.ListModelMixin,
  9. GenericAPIView):
  10. """
  11. Concrete view for listing a queryset.
  12. """
  13. def get(self, request, *args, **kwargs):
  14. return self.list(request, *args, **kwargs)
  15. class RetrieveAPIView(mixins.RetrieveModelMixin,
  16. GenericAPIView):
  17. """
  18. Concrete view for retrieving a model instance.
  19. """
  20. def get(self, request, *args, **kwargs):
  21. return self.retrieve(request, *args, **kwargs)
  22. class DestroyAPIView(mixins.DestroyModelMixin,
  23. GenericAPIView):
  24. """
  25. Concrete view for deleting a model instance.
  26. """
  27. def delete(self, request, *args, **kwargs):
  28. return self.destroy(request, *args, **kwargs)
  29. class UpdateAPIView(mixins.UpdateModelMixin,
  30. GenericAPIView):
  31. """
  32. Concrete view for updating a model instance.
  33. """
  34. def put(self, request, *args, **kwargs):
  35. return self.update(request, *args, **kwargs)
  36. def patch(self, request, *args, **kwargs):
  37. return self.partial_update(request, *args, **kwargs)
  38. class ListCreateAPIView(mixins.ListModelMixin,
  39. mixins.CreateModelMixin,
  40. GenericAPIView):
  41. """
  42. Concrete view for listing a queryset or creating a model instance.
  43. """
  44. def get(self, request, *args, **kwargs):
  45. return self.list(request, *args, **kwargs)
  46. def post(self, request, *args, **kwargs):
  47. return self.create(request, *args, **kwargs)
  48. class RetrieveUpdateAPIView(mixins.RetrieveModelMixin,
  49. mixins.UpdateModelMixin,
  50. GenericAPIView):
  51. """
  52. Concrete view for retrieving, updating a model instance.
  53. """
  54. def get(self, request, *args, **kwargs):
  55. return self.retrieve(request, *args, **kwargs)
  56. def put(self, request, *args, **kwargs):
  57. return self.update(request, *args, **kwargs)
  58. def patch(self, request, *args, **kwargs):
  59. return self.partial_update(request, *args, **kwargs)
  60. class RetrieveDestroyAPIView(mixins.RetrieveModelMixin,
  61. mixins.DestroyModelMixin,
  62. GenericAPIView):
  63. """
  64. Concrete view for retrieving or deleting a model instance.
  65. """
  66. def get(self, request, *args, **kwargs):
  67. return self.retrieve(request, *args, **kwargs)
  68. def delete(self, request, *args, **kwargs):
  69. return self.destroy(request, *args, **kwargs)
  70. class RetrieveUpdateDestroyAPIView(mixins.RetrieveModelMixin,
  71. mixins.UpdateModelMixin,
  72. mixins.DestroyModelMixin,
  73. GenericAPIView):
  74. """
  75. Concrete view for retrieving, updating or deleting a model instance.
  76. """
  77. def get(self, request, *args, **kwargs):
  78. return self.retrieve(request, *args, **kwargs)
  79. def put(self, request, *args, **kwargs):
  80. return self.update(request, *args, **kwargs)
  81. def patch(self, request, *args, **kwargs):
  82. return self.partial_update(request, *args, **kwargs)
  83. def delete(self, request, *args, **kwargs):
  84. return self.destroy(request, *args, **kwargs)

7、视图集

1)前言

视图集有4个类(ViewSet/GenericViewSet/ReadOnlyModelViewSet/ModelViewSet)具体参考源码。
GenericViewSet源码如下:

  1. class GenericViewSet(ViewSetMixin, generics.GenericAPIView):
  2. """
  3. The GenericViewSet class does not provide any actions by default,
  4. but does include the base set of generic view behavior, such as
  5. the `get_object` and `get_queryset` methods.
  6. """
  7. pass
  8. class ViewSetMixin:
  9. """
  10. This is the magic.
  11. Overrides `.as_view()` so that it takes an `actions` keyword that performs
  12. the binding of HTTP methods to actions on the Resource.
  13. For example, to create a concrete view binding the 'GET' and 'POST' methods
  14. to the 'list' and 'create' actions...
  15. view = MyViewSet.as_view({'get': 'list', 'post': 'create'})
  16. """
  17. @classonlymethod
  18. def as_view(cls, actions=None, **initkwargs):
  19. """
  20. Because of the way class based views create a closure around the
  21. instantiated view, we need to totally reimplement `.as_view`,
  22. and slightly modify the view function that is created and returned.
  23. """
  24. # The name and description initkwargs may be explicitly overridden for
  25. # certain route configurations. eg, names of extra actions.
  26. cls.name = None
  27. cls.description = None
  28. # The suffix initkwarg is reserved for displaying the viewset type.
  29. # This initkwarg should have no effect if the name is provided.
  30. # eg. 'List' or 'Instance'.
  31. cls.suffix = None
  32. # The detail initkwarg is reserved for introspecting the viewset type.
  33. cls.detail = None
  34. # Setting a basename allows a view to reverse its action urls. This
  35. # value is provided by the router through the initkwargs.
  36. cls.basename = None
  37. # actions must not be empty
  38. if not actions:
  39. raise TypeError("The `actions` argument must be provided when "
  40. "calling `.as_view()` on a ViewSet. For example "
  41. "`.as_view({'get': 'list'})`")
  42. # sanitize keyword arguments
  43. for key in initkwargs:
  44. if key in cls.http_method_names:
  45. raise TypeError("You tried to pass in the %s method name as a "
  46. "keyword argument to %s(). Don't do that."
  47. % (key, cls.__name__))
  48. if not hasattr(cls, key):
  49. raise TypeError("%s() received an invalid keyword %r" % (
  50. cls.__name__, key))
  51. # name and suffix are mutually exclusive
  52. if 'name' in initkwargs and 'suffix' in initkwargs:
  53. raise TypeError("%s() received both `name` and `suffix`, which are "
  54. "mutually exclusive arguments." % (cls.__name__))
  55. def view(request, *args, **kwargs):
  56. self = cls(**initkwargs)
  57. if 'get' in actions and 'head' not in actions:
  58. actions['head'] = actions['get']
  59. # We also store the mapping of request methods to actions,
  60. # so that we can later set the action attribute.
  61. # eg. `self.action = 'list'` on an incoming GET request.
  62. self.action_map = actions
  63. # Bind methods to actions
  64. # This is the bit that's different to a standard view
  65. for method, action in actions.items():
  66. handler = getattr(self, action)
  67. setattr(self, method, handler)
  68. self.request = request
  69. self.args = args
  70. self.kwargs = kwargs
  71. # And continue as usual
  72. return self.dispatch(request, *args, **kwargs)
  73. # take name and docstring from class
  74. update_wrapper(view, cls, updated=())
  75. # and possible attributes set by decorators
  76. # like csrf_exempt from dispatch
  77. update_wrapper(view, cls.dispatch, assigned=())
  78. # We need to set these on the view function, so that breadcrumb
  79. # generation can pick out these bits of information from a
  80. # resolved URL.
  81. view.cls = cls
  82. view.initkwargs = initkwargs
  83. view.actions = actions
  84. return csrf_exempt(view)
  85. def initialize_request(self, request, *args, **kwargs):
  86. """
  87. Set the `.action` attribute on the view, depending on the request method.
  88. """
  89. request = super().initialize_request(request, *args, **kwargs)
  90. method = request.method.lower()
  91. if method == 'options':
  92. # This is a special case as we always provide handling for the
  93. # options method in the base `View` class.
  94. # Unlike the other explicitly defined actions, 'metadata' is implicit.
  95. self.action = 'metadata'
  96. else:
  97. self.action = self.action_map.get(method)
  98. return request
  99. def reverse_action(self, url_name, *args, **kwargs):
  100. """
  101. Reverse the action for the given `url_name`.
  102. """
  103. url_name = '%s-%s' % (self.basename, url_name)
  104. namespace = None
  105. if self.request and self.request.resolver_match:
  106. namespace = self.request.resolver_match.namespace
  107. if namespace:
  108. url_name = namespace + ':' + url_name
  109. kwargs.setdefault('request', self.request)
  110. return reverse(url_name, *args, **kwargs)
  111. @classmethod
  112. def get_extra_actions(cls):
  113. """
  114. Get the methods that are marked as an extra ViewSet `@action`.
  115. """
  116. return [_check_attr_name(method, name)
  117. for name, method
  118. in getmembers(cls, _is_extra_action)]
  119. def get_extra_action_url_map(self):
  120. """
  121. Build a map of {names: urls} for the extra actions.
  122. This method will noop if `detail` was not provided as a view initkwarg.
  123. """
  124. action_urls = OrderedDict()
  125. # exit early if `detail` has not been provided
  126. if self.detail is None:
  127. return action_urls
  128. # filter for the relevant extra actions
  129. actions = [
  130. action for action in self.get_extra_actions()
  131. if action.detail == self.detail
  132. ]
  133. for action in actions:
  134. try:
  135. url_name = '%s-%s' % (self.basename, action.url_name)
  136. url = reverse(url_name, self.args, self.kwargs, request=self.request)
  137. view = self.__class__(**action.kwargs)
  138. action_urls[view.get_view_name()] = url
  139. except NoReverseMatch:
  140. pass # URL requires additional arguments, ignore
  141. return action_urls

a.可以继承视图集父类ViewSet
b.在定义url路由条目时,支持给as_view传递字典参数(请求方法名与具体调用的action方法名的一一对应关系)(如{‘get’:‘list’})
c.ViewSet继承了ViewSetMixin, views.APIView
d.具备APIView的所有功能,提供了身份认证、权限校验、流量管理等
e.继承ViewSetMixin,所有具备持给as_view传递字典参数(请求方法名与具体调用的action方法名的一一对应关系)

ViewSet视图集类不再实现get()、post()等方法,而是实现动作 action 如 list() 、create() 等:

  • list() 提供一组数据
  • retrieve() 提供单个数据
  • create() 创建数据
  • update() 保存数据
  • destory() 删除数据

视图集只在使用as_view()方法的时候,才会将action动作与具体请求方式对应上。如:

  1. from rest_framework.response import Response
  2. from demo.models import ClassInfo
  3. from demo.serializers import ClassInfoSerializer
  4. from rest_framework import viewsets, status
  5. class ClassViewSet(viewsets.ViewSet):
  6. # 获取所有班级数据
  7. def list(self, request):
  8. Classes = ClassInfo.objects.all()
  9. serializer = ClassInfoSerializer(Classes, many=True)
  10. return Response(serializer.data)
  11. def retrieve(self, request, pk=None):
  12. try:
  13. Class = ClassInfo.objects.get(id=pk)
  14. except ClassInfo.DoesNotExist:
  15. return Response(status=status.HTTP_404_NOT_FOUND)
  16. serializer = ClassInfoSerializer(Class)
  17. return Response(serializer.data)
  1. from django.urls import path
  2. from demo import views
  3. urlpatterns = [
  4. ······
  5. path('classes/', views.ClassViewSet.as_view({'get': 'list'})),
  6. path('classes/<int:pk>/', views.ClassViewSet.as_view({'get': 'retrieve'})),
  7. ]
2)ViewSet

继承自APIView与ViewSetMixin,作用也与APIView基本类似,提供了身份认证、权限校验、流量管理等。
ViewSet主要通过继承ViewSetMixin来实现在调用as_view()时传入字典(如{‘get’:‘list’})的映射处理工作。
在ViewSet中,没有提供任何动作action方法,需要我们自己实现action方法

3)GenericViewSet

使用ViewSet通常并不方便,因为list、retrieve、create、update、destory等方法都需要自己编写,而这些方法与前面讲过的Mixin扩展类提供的方法同名,所以我们可以通过继承Mixin扩展类来复用这些方法而无需自己编写。但是Mixin扩展类依赖与GenericAPIView,所以还需要继承GenericAPIView;

GenericViewSet就帮助我们完成了这样的继承工作,继承自GenericAPIView与ViewSetMixin,在实现了调用as_view()时传入字典(如{‘get’:‘list’})的映射处理工作的同时,还提供了GenericAPIView提供的基础方法,可以直接搭配Mixin扩展类使用
举例:

  1. from rest_framework import mixins
  2. from rest_framework.viewsets import GenericViewSet
  3. from rest_framework.decorators import action
  4. class ClassInfoViewSet(mixins.ListModelMixin, mixins.RetrieveModelMixin, GenericViewSet):
  5. queryset = ClassInfo.objects.all()
  6. serializer_class = ClassInfoSerializer
  1. urlpatterns = [
  2. ······
  3. path('classes_set/', views.ClassInfoViewSet.as_view({'get': 'list'})),
  4. path('classes_set/<int:pk>/', views.ClassInfoViewSet.as_view({'get': 'retrieve'})),
  5. ]
4)ModelViewSet和ReadOnlyModelViewSet类
  1. # a.ModelViewSet是一个最完整的视图集类
  2. # b.提供了获取列表数据接口、获取详情数据接口、创建数据接口、更新数据接口、删除数据的接口
  3. # c.如果需要多某个模型进行增删改查操作,才会选择ModelViewSet
  4. # d.如果仅仅只对某个模型进行数据读取操作(取列表数据接口、获取详情数据接口),一般会选择ReadOnlyModelViewSet
  5. class ProjectViewSet(viewsets.ModelViewSet):
  6. queryset = Projects.objects.all()
  7. serializer_class = ProjectModelSerializer
  8. filter_backends = [filters.SearchFilter, filters.OrderingFilter]
  9. search_fields = ['=name', '=leader', '=id']
  10. ordering_fields = ['id', 'name', 'leader']
  11. @action(methods=['GET'], detail=False)
  12. def names(self, request, *args, **kwargs):
  13. return super().list(request, *args, **kwargs)
  14. @action(detail=True)
  15. def interfaces(self, request, *args, **kwargs):
  16. project = self.get_object()
  17. interfaces_qs = project.interfaces_set.all()
  18. interfaces_data = [{'id': interface.id, 'name': interface.name} for interface in interfaces_qs]
  19. return Response(interfaces_data, status=200)

源码:

  1. # 源码
  2. class ReadOnlyModelViewSet(mixins.RetrieveModelMixin,
  3. mixins.ListModelMixin,
  4. GenericViewSet):
  5. """
  6. A viewset that provides default `list()` and `retrieve()` actions.
  7. """
  8. pass
  9. class ModelViewSet(mixins.CreateModelMixin,
  10. mixins.RetrieveModelMixin,
  11. mixins.UpdateModelMixin,
  12. mixins.DestroyModelMixin,
  13. mixins.ListModelMixin,
  14. GenericViewSet):
  15. """
  16. A viewset that provides default `create()`, `retrieve()`, `update()`,
  17. `partial_update()`, `destroy()` and `list()` actions.
  18. """
  19. pass
5)重写父类方法
  1. class ProjectViewSet(viewsets.ModelViewSet):
  2. def get_serializer_class(self):
  3. """
  4. a.可以重写父类的get_serializer_class方法,用于为不同的action提供不一样的序列化器类
  5. b.在视图集对象中可以使用action属性获取当前访问的action方法名称
  6. :return:
  7. """
  8. if self.action == 'names':
  9. return ProjectsNamesModelSerailizer
  10. else:
  11. # return self.serializer_class
  12. return super().get_serializer_class()
  13. def retrieve(self, request, *args, **kwargs):
  14. response = super().retrieve(request, *args, **kwargs)
  15. response.data.pop('id')
  16. response.data.pop('create_time')
  17. return response
  18. # def filter_queryset(self, queryset):
  19. # if self.action == "names":
  20. # return self.queryset
  21. # else:
  22. # return super().filter_queryset(queryset)
  23. def paginate_queryset(self, queryset):
  24. if self.action == "names":
  25. return
  26. else:
  27. return super().paginate_queryset(queryset)
  28. def get_queryset(self):
  29. if self.action == "names":
  30. return self.queryset.filter(name__icontains='2')
  31. else:
  32. return super().get_queryset()
6)类视图原则

如何定义类视图?类视图的设计原则?

  • a.类视图尽量要简单
  • b.根据需求选择相应的父类视图
  • c.如果DRF中的类视图有提供相应的逻辑,那么就直接使用父类提供的
  • d.如果DRF中的类视图,绝大多数逻辑都能满足需求,可以重写父类实现
  • e.如果DRF中的类视图完全不满足要求,那么就直接自定义即可
7)自定义action

在视图集中,除了上述默认的方法动作外,还可以添加自定义动作。
添加自定义动作需要使用rest_framework.decorators.action装饰器。
以action装饰器装饰的方法名会作为action动作名,与list、retrieve等同。

action装饰器可以接收两个参数:
methods: 该action支持的请求方式,列表传递,加上后可以自动获取路由,不写就默认为get
detail: 表示是action中要处理的是否是视图资源的对象(即是否通过url路径获取主键)
(1)True 表示使用通过URL获取的主键对应的数据对象
(2)False 表示不使用URL获取主键

  1. @action(methods=['GET'], detail=False)
  2. def names(self, request, *args, **kwargs):
  3. return super().list(request, *args, **kwargs)
  4. @action(detail=True)
  5. def interfaces(self, request, *args, **kwargs):
  6. project = self.get_object()
  7. interfaces_qs = project.interfaces_set.all()
  8. interfaces_data = [{'id': interface.id, 'name': interface.name} for interface in interfaces_qs]
  9. return Response(interfaces_data, status=200)
7)routers自动生成路由条目

使用routers自动生成路由条目:

  • 1、可以使用路由器对象,为视图集类自动生成路由条目
  • 2、路由器对象默认只为通用action(create、list、retrieve、update、destroy)生成路由条目,自定义的action不会生成路由条目
  • 3、创建SimpleRouter路由对象
  • 4、使用路由器对象调用register方法进行注册,register里面的参数是register(路由前缀,视图集,basename),访问时的路径则变为: (前缀)/路由前缀/函数名
  • 5、prefix指定路由前缀
  • 6、viewset指定视图集类,不可调用as_view
  • 7、加载路由条目:
    • 方式一:路由器对象.urls属性可获取生成的路由条目 include(router.urls)
    • 方式二:urlpatterns += router.urls,# router.urls为列表
      注意:如果是视图集类中自己定义的action,需要在自定义的action加上装饰器@action
  1. # -*- coding: utf-8 -*-
  2. from django.urls import path, include
  3. from rest_framework import routers
  4. from . import views
  5. router = routers.SimpleRouter()
  6. # DefaultRouter与SimpleRouter功能类似,仅有的区别为:DefaultRouter会自动生成一个根路由(显示获取数据的入口)
  7. # router = routers.DefaultRouter()
  8. router.register(r'projects', views.ProjectViewSet)
  9. urlpatterns = [
  10. # 7、加载路由条目
  11. # 方式一:
  12. # 路由器对象.urls属性可获取生成的路由条目
  13. path('', include(router.urls)),
  14. ]
  15. # 方式二:
  16. # router.urls为列表
  17. # urlpatterns += router.urls

七、API接口文档

1、coreapi

注意配置1:在配置文件settings.py中重新指定schema_class的配置

  1. REST_FRAMEWORK = {
  2. 'DEFAULT_SCHEMA_CLASS': 'rest_framework.schemas.coreapi.AutoSchema',
  3. # 新版drf schema_class默认用的是rest_framework.schemas.openapi.AutoSchema
  4. }

注意配置2:在setting文件的INSTALLED_APPS加入rest_framework,具体如下:

  1. INSTALLED_APPS = [
  2. ‘rest_framework’,]

然后urls中制定访问路由

  1. from rest_framework.documentation import include_docs_urls
  2. urlpatterns = [
  3. path('docs/', include_docs_urls(title='test接口文档', description='哈哈哈哈哈哈,这是哥的第一个接口文档'))
  4. ]

2、drf_yasg

INSTALLED_APPS = [‘drf_yasg’,]
  1. from drf_yasg.views import get_schema_view
  2. from drf_yasg import openapi
  3. # 固定写法
  4. schema_view = get_schema_view(
  5. openapi.Info(
  6. title="Lemon API接口文档平台", # 必传
  7. default_version='v1', # 必传
  8. description="这是一个美轮美奂的接口文档",
  9. terms_of_service="http://api.keyou.site",
  10. contact=openapi.Contact(email="keyou100@qq.com"),
  11. license=openapi.License(name="BSD License"),
  12. ),
  13. public=True,
  14. )
  15. urlpatterns = [
  16. re_path(r'^swagger(?P<format>\.json|\.yaml)$', schema_view.without_ui(cache_timeout=0), name='schema-json'),
  17. path('swagger/', schema_view.with_ui('swagger', cache_timeout=0), name='schema-swagger-ui'),
  18. path('redoc/', schema_view.with_ui('redoc', cache_timeout=0), name='schema-redoc'),
  19. ]

3、接口文档注解

可以通过在类视图下注解描述,即可在接口文档中显示

  1. class ProjectViewSet(viewsets.ModelViewSet):
  2. """
  3. list:
  4. 获取项目列表数据
  5. retrieve:
  6. 获取项目详情数据
  7. update:
  8. 更新项目信息
  9. names:
  10. 获取项目名称
  11. """

八、日志器

需要在settings.py中定义logging和loggers,
然后log = logging.getLogger(‘wl’)获取logger

  1. # 指定允许使用哪些地址访问当前系统
  2. ALLOWED_HOSTS = ['*']
  3. LOGGING = {
  4. # 指定日志版本
  5. 'version': 1,
  6. # 指定是否禁用其他日志,False为不禁用
  7. 'disable_existing_loggers': False,
  8. # 定义日志输出格式
  9. 'formatters': {
  10. # 简单格式
  11. 'simple': {
  12. 'format': '%(asctime)s - [%(levelname)s] - [msg]%(message)s'
  13. },
  14. # 复杂格式
  15. 'verbose': {
  16. 'format': '%(asctime)s - [%(levelname)s] - %(name)s - [msg]%(message)s - [%(filename)s:%(lineno)d ]'
  17. },
  18. },
  19. 'filters': {
  20. 'require_debug_true': {
  21. '()': 'django.utils.log.RequireDebugTrue',
  22. },
  23. },
  24. # 指定日志输出渠道(日志输出的地方)
  25. 'handlers': {
  26. # 指定在console控制台(终端)的日志配置行李箱
  27. 'console': {
  28. # 指定日志记录等级
  29. 'level': 'DEBUG',
  30. 'filters': ['require_debug_true'],
  31. 'class': 'logging.StreamHandler',
  32. 'formatter': 'simple'
  33. },
  34. # 指定在日志文件的配置信息
  35. 'file': {
  36. 'level': 'INFO',
  37. 'class': 'logging.handlers.RotatingFileHandler',
  38. 'filename': os.path.join(BASE_DIR, "logs/mytest.log"), # 日志文件的位置
  39. 'maxBytes': 100 * 1024 * 1024,
  40. 'backupCount': 10,
  41. 'formatter': 'verbose',
  42. 'encoding': 'utf-8'
  43. },
  44. },
  45. # 定义日志器
  46. 'loggers': {
  47. # 指定日志器的名称
  48. 'dev07': { # 定义了一个名为mytest的日志器
  49. 'handlers': ['console', 'file'],
  50. 'propagate': True,
  51. 'level': 'DEBUG', # 日志器接收的最低日志级别
  52. },
  53. }
  54. }

实际使用:

  1. # log使用
  2. log = logging.getLogger('wl')
  3. log.info("qqqqq")

九、认证器

1、session认证

settings.py中的rest_framework内指定DEFAULT_AUTHENTICATION_CLASSES和DEFAULT_PERMISSION_CLASSES

  1. # 指定使用的认证类
  2. # a.在全局指定默认的认证类(指定认证方式)
  3. 'DEFAULT_AUTHENTICATION_CLASSES': [
  4. # b.Session会话认证
  5. 'rest_framework.authentication.SessionAuthentication',
  6. 'rest_framework.authentication.BasicAuthentication'
  7. ],
  8. # 指定使用的权限类
  9. # a.在全局指定默认的权限类(当认证通过之后,可以获取何种权限)
  10. 'DEFAULT_PERMISSION_CLASSES': [
  11. # AllowAny不管是否有认证成功,都能获取所有权限
  12. # IsAdminUser管理员(管理员需要登录)具备所有权限
  13. # IsAuthenticated只要登录,就具备所有权限
  14. # IsAuthenticatedOrReadOnly,如果登录了就具备所有权限,不登录只具备读取数据的权限
  15. 'rest_framework.permissions.IsAuthenticatedOrReadOnly',
  16. ],
  1. # 在全局路由表中添加rest_framework.urls子路由
  2. # a.rest_framework.urls提供了登录和登出功能(返回的是一个HTML页面,并不是接口)
  3. path('api/', include('rest_framework.urls'))

2、token认证

安装

pip install djangorestframework-jwt

settings.py中增加配置 DEFAULT_AUTHENTICATION_CLASSES和JWT_AUTH

  1. REST_FRAMEWORK = {
  2. # 指定使用的认证类
  3. # a.在全局指定默认的认证类(指定认证方式)
  4. 'DEFAULT_AUTHENTICATION_CLASSES': [
  5. # 1)指定使用JWT TOKEN认证类
  6. # 2)在全局路由表中添加obtain_jwt_token路由(可以使用用户名和密码进行认证)
  7. # 3)认证通过之后,在响应体中会返回token值
  8. # 4)将token值设置请求头参数,key为Authorization,value为JWT token值
  9. 'rest_framework_jwt.authentication.JSONWebTokenAuthentication',
  10. # b.Session会话认证
  11. 'rest_framework.authentication.SessionAuthentication',
  12. 'rest_framework.authentication.BasicAuthentication'
  13. ],
  14. }
  15. JWT_AUTH={
  16. # 修改JWT TOKEN认证请求头中Authorization value值的前缀,默认为JWT
  17. # 'JWT_AUTH_HEADER_PREFIX': 'bearer',
  18. # 指定TOKEN过期时间,默认为5分钟,可以使用JWT_EXPIRATION_DELTA指定
  19. 'JWT_EXPIRATION_DELTA': datetime.timedelta(days=1),
  20. # 修改处理payload的函数
  21. 'JWT_RESPONSE_PAYLOAD_HANDLER':
  22. 'utils.handle_jwt_response.jwt_response_payload_handler',
  23. }

注意DEFAULT_AUTHENTICATION_CLASSES加在settings.py中默认全局生效,
但是实际使用时建议放在app的views.py中如下

  1. class ProjectViewSet(viewsets.ModelViewSet):
  2. ...
  3. # 在继承了APIView的类视图中,可以使用permission_classes类属性指定权限类,值为列表,可添加多个权限类
  4. permission_classes = [permissions.IsAuthenticated]
  5. ...
  1. # urls.py配置
  2. from rest_framework_jwt.views import obtain_jwt_token
  3. urlpatterns = [
  4. path('user/login/', obtain_jwt_token),
  5. ]

十、跨域问题

安装corsheaders

pip install django-cors-headers

使用

  1. INSTALLED_APPS = [ #注册应用
  2. 'corsheaders', #增加这个
  3. ]
  4. MIDDLEWARE = [ #中间件
  5. 'corsheaders.middleware.CorsMiddleware', #增加这个,放最前面
  6. 'django.middleware.security.SecurityMiddleware',
  7. ]
  8. CORS_ORIGIN_ALLOW_ALL = True
  9. CORS_ORIGIN_WHITELIST = () #白名单ip,可以不填
  10. # CORS_ORIGIN_WHITELIST指定能够访问后端接口的ip或域名列表
  11. # CORS_ORIGIN_WHITELIST = [
  12. # "http://127.0.0.1:8080",
  13. # "http://localhost:8080",
  14. # "http://192.168.1.63:8080",
  15. # "http://127.0.0.1:9000",
  16. # "http://localhost:9000",
  17. # ]
  18. CORS_ALLOW_CREDENTIALS = True # 允许携带cookie
  19. # 前端需要携带cookies访问后端时,需要设置
  20. # withCredentials=True
  21. CORS_ALLOW_METHODS = (
  22. 'DELETE',
  23. 'GET',
  24. 'OPTIONS',
  25. 'PATCH',
  26. 'POST',
  27. 'PUT',
  28. 'VIEW',
  29. )
  30. CORS_ALLOW_HEADERS = (
  31. 'accept',
  32. 'accept-encoding',
  33. 'authorization',
  34. 'content-type',
  35. 'dnt',
  36. 'origin',
  37. 'user-agent',
  38. 'x-csrftoken',
  39. 'x-requested-with',
  40. )
本文内容由网友自发贡献,转载请注明出处:https://www.wpsshop.cn/w/寸_铁/article/detail/894889
推荐阅读
相关标签
  

闽ICP备14008679号