tornado
2020-12-25 17:20:57 0 举报AI智能生成
登录查看完整内容
tornardo模块说明
作者其他创作
大纲/内容
tornado
platform
asyncio.py
class BaseAsyncIOLoop
class AsyncIOMainLoop
继承BaseAsyncIOLoop
class AsyncIOLoop
继承BaseAsyncIOLoop，实现asynio event loop
to_tornado_future
将asyncio.Future转换成tornado.concurrent.Future
to_asyncio_future
将Tornado yieldable转换成asyncio.Future
auto.py
引入monotonic_time以及根据os的类型，引入不同的Waker和set_close_exec函数
caresresolver.py
class CaresResolver
基于c语言库的dns解析，非阻塞，非线程级
common.py
try_close
尝试关闭文件
class Waker
创建os依赖的pipe，并实现waker接口
epoll.py
class EPollIOLoop
继承PollIOLoop类，实现initialize方法
interface.py
interface
set_close_exec
给文件描述符设置close_on_exec位
socket对象，当有object需要进行select(epoll或kqueue)操作的时候调用
monotonic_time
获取monotonic_time
kqueue.py
class KQueueIOLoop
class _KQueue
A kqueue-based event loop for BSD/Mac systems.
posix.py
set_close_exec(fd)
设置关闭fd时采取的动作和执行内容
_set_nonblocking
设置非阻塞方式
设置waker对象
select.py
class SelectIOLoop
继承PollIOLoop对象，实现initialized方法
class _Select
twisted.py
class TornadoDelayedCall
tornado延迟调用
class TornadoReactor
通过实现twisted接口实现ioloop
class _TestReactor
单元测试
class install
安装io_loop作为twisted reactor
class _FD
class TwistedIOLoop
继承salt.ext.tornado.ioloop.IOLoop，实现twisted的方式
class TwistedResolver
异步解析twisted的dns信息
windows.py
关闭fd时执行的内容
test
_locale_data.py
定义各种语言的名称/英文名等
auth.py
_auth_future_to_callback
调用callback函数，处理future的返回结果
_auth_return_future
装饰器，与return_future方式相同，使用的时auth 模块
class OpenIdMixin
实现OpenID的验证方式
class OAuthMixin
实现OAuth 1.0的方式
class OAuth2Mixin
实现OAuth 2.0的方式
class TwitterMixin
实现twitter auth方式
class GoogleOAuth2Mixin
实现google auth2方式
class FacebookGraphMixin
实现facebook graph api和auth2方式
_oauth_signature
计算HMAC-SHA1 OAuth签名方式
_oauth10a_signature
计算HMAC-SHA1 OAuth 1.0a签名方式
_oauth_escape
对val进行quote操作
_oauth_parse_response
获取token
autoreload.py
_reload
调用reload hook执行重新加载
add_reload_hook
reload process之前添加function调用
_check_file
检查文件st_mtime是否已经修改
_reload_on_update
检查是否需要reload
watch
添加文件到watch list
wait
等待文件改变，重启process
start
启动文件监控
concurrent.py
class _TracebackLogger
追踪exception信息
class Future
处理asynchronous 结果
is_future
判断是否为future类型
class DummyExecutor
空执行
run_on_executor
装饰器运行在executor上异步运行同步方法，并返回future对象
return_future
装饰器，使得func通过callback返回Future对象
chain_future
链接两个futures到一起，保证两个同时完成
curl_httpclient.py
class CurlAsyncHTTPClient
异步HTTP client处理程序
escape.py
xhtml_escape
使得xml或者html合法化
def xhtml_unescape(value):
xml变回原有信息
json_encode
json dumps
json_decode
json loads
squeeze
连续空格变成一个
url_escape
url quote
url_unescape
url unquote
utf8
encode utf8
to_unicode
decode utf8
to_basestring
recursive_unicode
递归进行unicode转换
linkify
Converts plain text into HTML with links
gen.py
_value_from_stopiteration
返回stopiteration的信息
engine
装饰器实现func的future和callback
coroutine
装饰器实现异步调用
_make_coroutine_wrapper
真正实现coroutine内部调用的函数
is_coroutine_function
判断func是不是coroutine函数
class Return
指定coroutine返回的exception
class WaitIterator
提供iterator，在future结束后提供yield result
class YieldPoint
基础类，用于适应那些需要yield操作的对象
class Callback
返回一个callable对象，允许匹配wait去调用
class Wait
获取之前callback返回的result
class WaitAll
获取之前所有callback返回的result
Task
调用任务并返回结果
class YieldFuture
yield Point的future动作，并取回结果
_contains_yieldpoint
如果children包含yieldPoints点
multi
运行多重异步并行操作
class MultiYieldPoint
与multi类似，但是总是创建stack context方法，不兼容原声coroutines
multi_future
等待并行调用future执行结果
maybe_future
如果时future类则返回，否则创建future对象返回
with_timeout
future timeout调用方式
sleep
gen的sleep方式
class Runner
内部实现gen engine，管理callbacks的信息和result结果
_argument_adapter
根据参数个数，调用callback函数并传输不同类型的参数
convert_yielded
将yielded对象转换成Future
http1connection.py
class _QuietException
异常退出基类
class _ExceptionLoggingContext
提供with方法输出异常信息
class HTTP1ConnectionParameters
HTTP1Connection和HTTP1ServerConnection的参数类
class HTTP1Connection
实现http 1.x protocal
class _GzipMessageDelegate
包装HTTPMessage，生成Content-Encoding: gzip类型数据
class HTTP1ServerConnection
HTTP 1.x Server
httpclient.py
class HTTPClient
阻塞的http client对象
class AsyncHTTPClient
非阻塞的HTTP client
class HTTPRequest
HTTPRequest对象
class HTTPResponse
HTTPResponse对象
class HTTPError
HTTP请求异常处理
class _RequestProxy
获取request的属性
httpserver.py
class HTTPServer
非阻塞的单线程http-server
class _CallableAdapter
继承httputil.HTTPMessageDelegate实现HTTP消息处理
class _HTTPRequestContext
保留socket address或header相关信息，在stream close后恢复
class _ProxyAdapter
proxy adapter处理
httputil.py
class _NormalizedHeaderCache
将http header的名称替换成大写字母开头内容
class HTTPHeaders
定义http header处理方法
class HTTPServerRequest
生成http request单一请求
class HTTPInputError
管理http request和response的异常请求
class HTTPOutputError
http输出异常处理
class HTTPServerConnectionDelegate
实现httpServer处理程序的接口
class HTTPMessageDelegate
实现http request或response处理接口
class HTTPConnection
应用程序使用此接口写response信息
url_concat
连接url和参数，形成完整url
class HTTPFile
代表文件上传form对象
_parse_request_range
获取header范围
_get_content_range
返回可用的content range
_int_or_none
将val转换成数字或者返回NOne
parse_body_arguments
生成form 请求实体
parse_multipart_form_data
生成multipart/form-data实体
format_timestamp
返回timestamp
parse_request_start_line
parse_response_start_line
_parseparam
yield方式输出所有的param
_parse_header
将Content-type类型的header转换成key value形式
_encode_header
将header类型数据转换成字符串
split_host_and_port
去除host，port列表
_unquote_cookie
去除cookie双引号
parse_cookie
将Cookie http header信息转换成字典类型
ioloop.py
class IOLoop
定义epoll，kqueue，等的io事件/handler/fd等关系
class PollIOLoop
建立select的handler等处理内容
class _Timeout
ioloop timeout对象
class PeriodicCallback
callback周期性调用内容
iostream.py
class StreamClosedError
当stream关闭时产生IOStream close error
class UnsatisfiableReadError
当read操作不满足时产生exception
class StreamBufferFullError
当buffer满后产生exception
class BaseIOStream
基础工具类，用于写入或者读取文件或socket内容
class IOStream
基于BaseIOStream同时增加connect信息
class SSLIOStream
基于IOStream类，增加ssl和certify方式
class PipeIOStream
基于BaseIOStream，增加对fd的操作
locale.py
get
获取给定locale codes最接近的内容
set_default_locale
设置supported locales
locks.py
class _TimeoutGarbageCollector
基础类周期性清理未完成对象
class Condition
按条件等待其他coroutines调用
class Event
事件阻塞协程直到flag被设置成True
class _ReleasingContextManager
with指令后释放lock和semaphore
class Semaphore
一种可以同时容纳多个lock的锁机制
class BoundedSemaphore
继承Semaphore，保证release的次数不超过initial_value
class Lock
对coroutines加锁
log.py
_stderr_supports_color
stderr是否支持颜色
class LogFormatter
定义log 模式
enable_pretty_logging
开始完美日志输出
define_logging_options
定义日志参数
load_translations
从csv文件中加载内容
load_gettext_translations
通过gettext方式获取类似/usr/share/locale下的translations
get_supported_locales
获取locales的列表
class Locale
创建locale对象
class CSVLocale
使用tornado CSV转换方式定位信息
class GettextLocale
使用gettext模块定位信息
netutil.py
bind_sockets
绑定端口和地址，返回sockets对象
bind_unix_socket
绑定unix socket到文件
add_accept_handler
添加event到ioloop handler，接收sock新请求
is_valid_ip
检查ip地址是否格式正确
class Resolver
配置dns解析interface
class ExecutorResolver
继承Resolver，做执行解析
class BlockingResolver
ioloop在解析过程中将要阻断
class ThreadedResolver
多线程非阻塞方式resolver实现
class OverrideResolver
本地DNS解析对照表，这种方法可以用于修改内存中存储的本地DNS配置
ssl_options_to_context
将ssl_options字典转换成对象
ssl_wrap_socket
根据ssl_options，生成socket对象
options.py
class OptionParser
参数定制管理
class _Mockable
兼容OptionParser，将字典类型转换成getter setter类型
class _Option
对格式进行转化
define
调用optionParser.define
parse_command_line
调用OptionParser.parse_command_line
parse_config_file
调用OptionParser.parse_config_file
print_help
调用OptionParser.print_help
add_parse_callback
调用OptionParser.add_parse_callback
process.py
cpu_count
统计cpu颗数
_reseed_random
产生随机变量
_pipe_cloexec
产生读写文件符
fork_processes
根据cpu颗数产生子线程
task_id
返回当前task_id信息
class Subprocess
类似于subprocess.Popen的并生成PipeIOStream处理
queues.py
class QueueEmpty
class QueueFull
如果queue是满的则报错
_set_timeout
定义超时handle，以及done_callback函数
class _QueueIterator
异步生成器awailable对象
class Queue
getter队列和putter队列协作
class PriorityQueue
继承Queue，实现put，get，init功能
class LifoQueue
routing.py
class Router
router的接口
class ReversibleRouter
继承自Router类，实现将route名称转换成原始url
class _RoutingDelegate
class RuleRouter
class ReversibleRuleRouter
class Rule
定义rule对象
class Matcher
匹配request请求，形成url
class AnyMatches
匹配所有请求
class HostMatches
继承Matcher，匹配host名称
class DefaultHostMatches
继承Matcher，对request的host进行匹配，如果headers中包含X-Real-Ip内容，则总是返回None
class PathMatches
继承Matcher，按照path_pattern对request进行path匹配
class URLSpec
继承Rule，对URL和handler进行mapping操作
_unquote_or_none
非安全模式的url_unescape
simple_httpclient.py
_default_ca_certs
返回certifi的位置
class SimpleAsyncHTTPClient
实现非阻塞的http client类
class _HTTPConnection
http Connection用于连接的对象
tcpclient.py
class _Connector
Happy Eyeballs算法的无状态实现，getaddrinfo首先返回的链路，作为连接链路
class TCPClient
非阻塞的TCP连接工厂
tcpserver.py
class TCPServer
定义非阻塞的单线程TCP server
template.py
filter_whitespace
根据模式对空白字符进行缩进转换
class Template
创建模板对象
class BaseLoader
template基础loader对象
class Loader
继承BaseLoader，根据path解析并加载template
class DictLoader
继承BaseLoader，根据字典加载template
...
util.py
class ObjectDict
使字典行为拥有对象的能力
class GzipDecompressor
进行gzip压缩
import_object
import对象
errno_from_exception
从exception中获取errno信息
re_unescape
替换某些特殊字符串
class Configurable
配置基类
timedelta_to_seconds
时间戳的秒数
wsgi.py
web.py
class RequestHandler
http请求handler的基类，实现请求所需的基本函数
asynchronous
装饰器，实现request handler的异步调用
removeslash
装饰器，移除url末尾的/
addslash
装饰器，url末尾添加/
class _ApplicationRouter
继承ReversibleRuleRouter，实现Application和RequestHandler之间的绑定
class Application
继承自ReversibleRouter，实现url与handler的绑定处理等动作
class_HandlerDelegate
http error response的exception处理
class Finish
结束请求的异常处理
class MissingArgumentError
缺失参数的异常
class ErrorHandler
对所有requests生成带status_code的error response
class RedirectHandler
重定向请求地址
class StaticFileHandler
静态文件handler处理
class FallbackHandler
继承RequestHandler，装饰器，调用callback函数
class OutputTransform
转换修正http 请求的结果集
class GZipContentEncoding
继承OutputTransform，对response内容进行gzip压缩
authenticated
装饰器，用于验证user是否登陆，如果没有登陆则跳转至登陆页面
get_signature_key_version
获取签名key_version
_create_signature_v1
创建sha256加密
_create_signature_v2
创建sha1的加密
is_absolute
是否是绝对路径
websocket.py
class WebSocketHandler
websocket 基础处理程序
class WebSocketProtocol
websocket 协议的基础类
class _PerMessageDeflateCompressor
message 压缩
class _PerMessageDeflateDecompressor
message 解压缩
class WebSocketProtocol13
继承WebSocketProtocal，实现RFC6455 websocket协议
class WebSocketClientConnection
webSocket client连接对象，不要直接调用，应该使用websocket_connect调用
websocket_connect
websocket 客户端支持
stack_context.py
class StackContext
stack context处理enter exit问题
class ExceptionStackContext
详细处理stack exception内容
class NullContext
重置stack context
_remove_deactivated
去除chain中的deactivated handlers
wrap
返回fun的可执行对象
0 条评论
回复 删除
下一页
