介绍

使用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:
        span.set_tag('component', request.app.name)
        span.finish()
    return response

• 创建span, 用于日志追踪

• 对response进行封装，统一格式

异常处理 

对抛出的异常进行处理，返回统一格式

任务 

创建task消费queue中对span，用于日志追踪

异步处理 

由于使用的是异步框架，可以将一些IO请求并行处理

Example:

async def async_request(datas):
    # async handler request
    results = await asyncio.gather(*[data[2] for data in datas])
    for index, obj in enumerate(results):
        data = datas[index]
        data[0][data[1
                            
                            版权声明：本文来源CSDN，感谢博主原创文章，遵循 CC 4.0 by-sa 版权协议，转载请附上原文出处链接和本声明。

                            原文链接：https://blog.csdn.net/BF02jgtRS00XKtCx/article/details/79226933

                            站方申明：本站部分内容来自社区用户分享，若涉及侵权，请联系站方删除。