Sanic框架流式传输操作示例
时间:2018-07-18
这篇文章主要介绍了Sanic框架流式传输操作,结合实例形式分析了Sanic通过流请求与响应传输操作相关实现技巧与注意事项,需要的朋友可以参考下
本文实例讲述了Sanic框架流式传输操作。分享给大家供大家参考,具体如下:
简介
Sanic是一个类似Flask的Python 3.5+ Web服务器,它的写入速度非常快。除了Flask之外,Sanic还支持异步请求处理程序。这意味着你可以使用Python 3.5中新的闪亮的异步/等待语法,使你的代码非阻塞和快速。
在前面一篇《Sanic框架Cookies操作》中已经讲到,如何在Sanic中使用Cookie,接下来将介绍一下Sanic的流的使用:
请求流式传输
Sanic允许通过流获取请求数据,如下所示,当请求结束时,request.stream.get()
返回为None
,只有post
、put
和patch decorator
拥有流参数:
from sanic.response import stream @app.post("/post_stream",stream=True) async def post_stream(request): async def streaming(response): while True: body = await request.stream.get() if body is None: break body = body.decode("utf-8") reponse.write(body) return stream(streaming) @app.put("/put_stream",stream=True) async def put_stream(request): async def streaming(response): while True: body = await request.stream.get() if body is None: break body = body.decode("utf-8") response.write("utf-8") return stream(streaming)
除了上述例子的方法之外,我们之前还讲过用add_route
方法动态添加路由:
from sanic.response import text from sanic.views import HTTPMethodView from sanic.views import stream as stream_decorator class StreamView(HTTPMethodView) @stream_decorator async def post(self,request) result = '' while True: body = await request.stream.get() if body is None: break body = body.decode('utf-8') result += body return text(result) app.add_route(StreamView.as_view(),"/method_view")
值得注意的是,stream_decorator
装饰器中处理函数的函数名称,若为post则为post请求,若为put则为put请求。在之前讲述路由的文章《Sanic框架路由用法》中讲到一个CompositionView
类来自定义一个路由,CompositionView
在流式请求中同样适用:
from sanic.views import CompositionView async def post_stream_view(request): result = '' while True: body = await request.stream.get() if body is None: break body = body.decode('utf-8') result += body return text(result) view = CompositionView() view.add(['POST'],post_stream_view,stream=True) app.add_route(view,"/post_stream_view")
响应流式传输
Sanic允许你使用stream
方法将内容传输到客户端,该方法接受一个通过StreamingHTTPResponse
传入的对象的协程回调,举个栗子:
from sanic.response import stream @app.route("/post_stream_info",methods=["POST"]) async def post_stream_info(request): async def streaming(response): response.write("no") response.write("bug") return stream(streaming)
更多关于Python相关内容可查看本站专题:《Python入门与进阶经典教程》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
- 大型分布式网站架构技术总结
- MySQL和Oracle对比之存储过程(r5笔记第7天)
- 07.Java变量类型
- OAuth 2.0验证【面试+工作】
- MySQL备份恢复第一篇(r5笔记第5天)
- 经典面试问题: Top K 之 -- 海量数据找出现次数最多或,不重复的
- Java多线程详解4【面试+工作】
- Java多线程详解5【面试+工作】
- Java多线程详解6【面试+工作】
- MySQL备份恢复第二篇(r5笔记第6天)
- SpringMVC 中配置 Swagger 插件.
- MySQL和Oracle对比学习之事务(r5笔记第4天)
- 【面试宝典】Java如何打印数组
- MySQL数据导入导出牛刀小试(r5笔记第3天)
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- PNN:Product-based Neural Networks for User Response Prediction
- Redis | Redis Pub/Sub相关命令
- nginx upstream header过大是啥情况
- 8个写JavaScript代码的小技巧
- .NET Core中间件与依赖注入的一些思考
- 如何审计MySQL 8.0中的分类数据查询?
- 聊一个 GitHub 上开源的 RBAC 权限管理系统,很6!
- Spring AOP,应该不会有比这更详细的介绍了!
- 我又发现 Spring Security 中一个小秘密!
- OpenCV的实用图像处理操作案例分享
- CentOS 7上搭建 Zabbix4.0,一次性成功,收藏了!
- 超全!我整理一波最常用的开源项目
- 【NLP】竞赛必备的NLP库
- Java NIO Selector 详解
- 【机器学习基础】一文搞懂机器学习里的L1与L2正则化