基于Sanic的微服务基础架构 - (EPUB全文下载)

文件大小：0.34 mb。
文件格式：epub 格式。
书籍内容：

基于Sanic的微服务基础架构
Python中文社区
Main Title and Escape John Williams - Star Wars: The Last Jedi (Original Motion Picture Soundtrack)
介绍
使用python做web开发面临的一个最大的问题就是性能，在解决C10K问题上显的有点吃力。有些异步框架Tornado、Twisted、Gevent 等就是为了解决性能问题。这些框架在性能上有些提升，但是也出现了各种古怪的问题难以解决。
在python3.6中，官方的异步协程库asyncio正式成为标准。在保留便捷性的同时对性能有了很大的提升,已经出现许多的异步框架使用asyncio。
使用较早的异步框架是aiohttp，它提供了server端和client端，对asyncio做了很好的封装。但是开发方式和最流行的微框架flask不同，flask开发简单，轻量，高效。
微服务是最近最火开发模式，它解决了复杂性问题，提高开发效率，便于部署等优点。
正是结合这些优点, 以Sanic为基础，集成多个流行的库来搭建微服务。 Sanic框架是和Flask相似的异步协程框架，简单轻量，并且性能很高。
本项目就是以Sanic为基础搭建的微服务框架。
特点
使用sanic异步框架，简单，轻量，高效。
使用uvloop为核心引擎，使sanic在很多情况下单机并发甚至不亚于Golang。
使用asyncpg为数据库驱动，进行数据库连接，执行sql语句执行。
使用aiohttp为Client，对其他微服务进行访问。
使用peewee为ORM，但是只是用来做模型设计和migration。
使用opentracing为分布式追踪系统。
使用unittest做单元测试，并且使用mock来避免访问其他微服务。
使用swagger做API标准，能自动生成API文档。
使用
项目地址
sanic-ms:
`https://github.com/songcser/sanic-ms`
Example
:
`https://github.com/songcser/sanic-ms/tree/master/examples`
Swagger API
Zipkin Server
服务端
使用sanic异步框架，有较高的性能，但是使用不当会造成blocking, 对于有IO请求的都要选用异步库。添加库要慎重。 sanic使用uvloop异步驱动，uvloop基于libuv使用Cython编写，性能比nodejs还要高。
功能说明
启动前
@app
.listener(
'before_server_start'
)
async
 
def
 before_srver_start(app, loop):
    queue = asyncio.
Queue
()
    app.queue = queue
    loop.create_task(consume(queue, app.config.ZIPKIN_SERVER))
    reporter = 
AioReporter
(queue=queue)
    tracer = 
BasicTracer
(recorder=reporter)
    tracer.register_required_propagators()
    opentracing.tracer = tracer
    app.db = 
await
 
ConnectionPool
(loop=loop).init(DB_CONFIG)
创建DB连接池
创建Client连接
创建queue, 消耗span，用于日志追踪
创建opentracing.tracer进行日志追踪
中间件
@app
.middleware(
'request'
)
async
 
def
 cros(request):
    
if
 request.method == 
'POST'
 
or
 request.method == 
'PUT'
:
        request[
'data'
] = request.json
    span = before_request(request)
    request[
'span'
] = span
@app
.middleware(
'response'
)
async
 
def
 cors_res(request, response):
    span = request[
'span'
] 
if
 
'span'
 
in
 request 
else
 
None
    
if
 response 
is
 
None
:
        
return
 response
    result = {
'code'
: 
0
}
    
if
 
not
 isinstance(response, 
HTTPResponse
):
        
if
 isinstance(response, tuple) 
and
 len(response) == 
2
:
            result.update({
                
'data'
: response[
0
],
                
'pagination'
: response[
1
]
            })
        
else
:
            result.update({
'data'
: response})
        response = json(result)
        
if
 span:
            span.set_tag(
'http.status_code'
, 
"200"
)
    
if
 span:
        sp ............

书籍插图：

以上为书籍内容预览，如需阅读全文内容请下载EPUB源文件，祝您阅读愉快。