Python对Tornado请求与响应的数据处理

Yelena ·
更新时间:2024-11-14
· 509 次阅读

获取查询字符串参数

get_query_argument(name, default=_ARG_DEFAULT, strip=True)

从请求的查询字符串中返回指定参数name的值,如果出现多个同名参数,则返回最后一个的值;

default为路由中未传name参数时返回的默认值,如default未设置,则会抛出tornado.web.MissingArgumentError异常;

strip表示是否过滤掉左右两边的空白字符,默认为过滤。

get_query_arguments(name, strip=True)

从请求的查询字符串中返回指定参数name的值,注意返回的是list列表(即使对应name参数只有一个值),若未找到name参数,则返回空列表。

获取请求体数据

get_body_argument(name, default=_ARG_DEFAULT, strip=True)

从请求体中返回指定参数name的值,如出现多个同名参数,则返回最后一个的值;

default与strip同上。

get_body_arguments(name, strip=True)

从请求体中返回指定参数name的值,注意返回的是list列表(即使对应name参数只有一个值),若未找到name参数,则返回空列表。

说明:对于请求体中数据为json或xml的,无法通过这两个方法获取。

前两类方法的整合

get_argument(name, default=_ARG_DEFAULT, strip=True)

get_arguments(name, strip=True)

说明:对于请求体中数据为json或xml的,无法通过这两个方法获取。

这两个方法最常用

获取请求体中的json或xml数据

body_json = self.request.body

body_dict = json.loads(body_json)

需要先判断请求体的数据是否为 application/json 格式:

if self.reuqest.headers.get("Content-Type", "").startswith("application/json"): try: # 防止请求头内容是application/json,实际内容不是json数据 body_dict = json.loads(self.request.body) except Exception as e: logger({"message": e}) body_dict = dict() 正则提取uri中的参数

第一种是未命名的方式,按照匹配顺序进行传递:

... def get(self, subject, city): ... (r"/subject/(.+)/(.+)", SubjectCityHandler), ...

第二种是以命名的方式进行传递:

... def get(self, city, date): ... (r"/subject/(?P<date>.+)/(?P<city>.+)", SubjectCityHandler), ... Tornado的Request对象属性
属性 说明
self.request.method  http的请求头;get, post等
self.reuqest.uri  客户端请求完整的uri
self.request.path  uri的路径名,不包含查询的字符串
self.request.query uri中的查询字符串
self.request.version http/1.1
self.request.headers 请求头
self.requset.body 字符串的消息
self.request.remote_ip 客户端请求的ip
self.request.protocol http的协议http or https
self.request.host 请求消息的主机名
self.request.files 以字典的方式表达客户端上传的文件
self.request.cookies 客户端的cookies字典
self.request.arguments  客户端提交的参数
import tornado.web import tornado.ioloop import tornado.httpserver import tornado.options # 新导入的options模块 tornado.options.define("port", default=8000, type=int, help="服务器监听端口号") tornado.options.define("content", default=[], type=str, multiple=True, help="控制台输出内容") class IndexHandler(tornado.web.RequestHandler): """主路由处理类""" def get(self): self.write("Hello World!") self.write("\n-------method:\n") self.write(self.request.method) self.write("\n-------uri:\n") self.write(self.request.uri) self.write("\n-------path:\n") self.write(self.request.path) self.write("\n-------query:\n") self.write(self.request.query) self.write("\n-------version:\n") self.write(self.request.version) self.write("\n-------headers['Accept-Language']:\n") self.write(self.request.headers["Accept-Language"]) self.write("\n-------body:\n") self.write(self.request.body) self.write("\n-------remote_ip:\n") self.write(self.request.remote_ip) self.write("\n-------protocol:\n") self.write(self.request.protocol) self.write("\n-------host:\n") self.write(self.request.host) self.write("\n-------arguments:\n") self.write(self.request.arguments) self.write("\n-------query_arguments:\n") self.write(self.request.query_arguments) self.write("\n-------body_arguments:\n") self.write(self.request.body_arguments) self.write("\n-------files:\n") self.write(self.request.files) self.write("\n-------cookies:\n") self.write(self.request.cookies) self.write("\n") #自定义settings settings = { "template_path":"templates", "static_path":"statics", } if __name__ == "__main__": tornado.options.parse_config_file("./config") print(tornado.options.options.content) # 控制台输出内容 app = tornado.web.Application([ (r"/", IndexHandler), ],debug=True,**settings) http_server = tornado.httpserver.HTTPServer(app) http_server.listen(tornado.options.options.port)

更多关于Python对Tornado请求与响应的数据处理方法请查看下面的相关链接

您可能感兴趣的文章:Python爬虫库requests获取响应内容、响应状态码、响应头python按键按住不放持续响应的实例代码python定时检测无响应进程并重启的实例代码Python按钮的响应事件详解关于python下cv.waitKey无响应的原因及解决方法python通过get,post方式发送http请求和接收http响应的方法Python响应对象text属性乱码解决方案



tornado 数据处理 数据 Python

需要 登录 后方可回复, 如果你还没有账号请 注册新账号