早报:《这是自身的烟尘》开发商领衔,波兰独自游戏厂商大举进军国内

单元测试

单元测试使用unittest。
mock是友善创建了MockClient,因为unittest还未曾asyncio的mock,并且sanic的测试接口也是殡葬request请求,所以相比较麻烦.
先前时期可以拔取pytest。

Example:

from sanic_ms.tests import APITestCase
from server import app

class TestCase(APITestCase):
    _app = app
    _blueprint = 'visit'

    def setUp(self):
        super(TestCase, self).setUp()
        self._mock.get('/cities/1',
                       payload={'id': 1, 'name': 'shanghai'})
        self._mock.get('/roles/1',
                       payload={'id': 1, 'name': 'shanghai'})

    def test_create_user(self):
        data = {
            'name': 'test',
            'age': 2,
            'city_id': 1,
            'role_id': 1,
        }
        res = self.client.create_user(data=data)
        body = ujson.loads(res.text)
        self.assertEqual(res.status, 200)
  • 其中_blueprint为blueprint名称
  • 在setUp函数中,使用_mock来注册mock音讯, 这样就不会访问真正的服务器,
    payload为回去的body音讯
  • 使用client变量调用各类函数,
    data为body消息,params为路径的参数新闻,其他参数是route的参数

4.《城市:天际线》“黄色之城”扩张包上线,序列折扣持续中

中间件

@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进行包装,统一格式

挪动之间,游戏师长出席新形式“无尽远征”,原本争权格局中的杂兵将被骷髅代替,这么些遗骨固然可以一击杀死,但它们的攻击力比经常士兵强大的多。

丰富处理

使用 app.error_handler = CustomHander() 对抛出的丰裕举行处理

Example:

from sanic_ms.exception import ServerError

@visit_bp.delete('/users/<id:int>')
async def del_user(request, id):
    raise ServerError(error='内部错误',code=10500, message="msg")
  • code: 错误码,无丰裕时为0,另外值都为异常
  • message: 状态码音讯
  • error: 自定义错误音信
  • status_code: http状态码,使用专业的http状态码

2.《空洞骑士》第二个免费扩大包下一周上线

介绍

行使python做web开发面临的一个最大的题目就是性质,在缓解C10K问题上显的有点困难。有些异步框架Tornado、Twisted、Gevent
等就是为着解决性能问题。这个框架在性能上稍稍提高,不过也油不过生了各个奇异的题材难以解决。

在python3.6中,官方的异步协程库asyncio正式成为专业。在保留便捷性的还要对性能有了很大的升级,已经面世过多的异步框架使用asyncio。

选择较早的异步框架是aiohttp,它提供了server端和client端,对asyncio做了很好的包装。但是开发形式和最盛行的微框架flask不同,flask开发简单,轻量,高效。

微服务是最近最火开发情势,它解决了复杂问题,提升开支功用,便于安排等优点。

幸而结合那多少个亮点, 以Sanic为底蕴,集成六个流行的库来搭建微服务。
Sanic框架是和Flask相似的异步协程框架,简单轻量,并且性能很高。

本项目就是以Sanic为根基搭建的微服务框架。

美利坚同盟国卡脚模拟》在杉果有售,感兴趣的玩家不妨来看望。

使用

尽管如此官方尚未披露“新墨西哥”何时能与我们晤面,然则她们表示那么些DLC已经八九不离十完工了。

异步处理

由于使用的是异步框架,可以将有些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]] = results[index]

@user_bp.get('/<id:int>')
@doc.summary("get user info")
@doc.description("get user info by id")
@doc.produces(Users)
async def get_users_list(request, id):
    async with request.app.db.acquire(request) as cur:
        record = await cur.fetch(
            """ SELECT * FROM users WHERE id = $1 """, id)
        datas = [
            [record, 'city_id', get_city_by_id(request, record['city_id'])]
            [record, 'role_id', get_role_by_id(request, record['role_id'])]
        ]
        await async_request(datas)
        return record

get_city_by_id, get_role_by_id是并行处理。

就像你预料的一致,新墨西哥具备震撼的大山里和孤寂的高速公路,游戏中似乎还会暴发阻碍交通的坠机事件,emmm……坠机这种严重事故真的有那么频繁吗?

模型设计 & ORM

Peewee is a simple and small ORM. It has few (but expressive)
concepts, making it easy to learn and intuitive to use。

ORM使用peewee, 只是用来做模型设计和migration, 数据库操作使用asyncpg。

Example:

# models.py

class Users(Model):
    id = PrimaryKeyField()
    create_time = DateTimeField(verbose_name='create time',
                                default=datetime.datetime.utcnow)
    name = CharField(max_length=128, verbose_name="user's name")
    age = IntegerField(null=False, verbose_name="user's age")
    sex = CharField(max_length=32, verbose_name="user's sex")
    city_id = IntegerField(verbose_name='city for user', help_text=CityApi)
    role_id = IntegerField(verbose_name='role for user', help_text=RoleApi)

    class Meta:
        db_table = 'users'


# migrations.py

from sanic_ms.migrations import MigrationModel, info, db

class UserMigration(MigrationModel):
    _model = Users

    # @info(version="v1")
    # def migrate_v1(self):
    #     migrate(self.add_column('sex'))

def migrations():
    try:
        um = UserMigration()
        with db.transaction():
            um.auto_migrate()
            print("Success Migration")
    except Exception as e:
        raise e

if __name__ == '__main__':
    migrations()
  • 运行命令 python migrations.py
  • migrate_v1函数添加字段sex, 在BaseModel中要先添加name字段
  • info装饰器会创造表migrate_record来记录migrate,version每个model中务必唯一,使用version来记录是否执行过,还足以记录author,datetime
  • migrate函数必须以migrate_开头

另外,11 bit
studios即将代理发行的几款来自波兰独立游戏开发者的游艺随笔如《寒霜重打击乐》(Frostpunk)、《57号塔》(Tower
57)、《夜勤人》(Moonlighter)等也将在上架杉果,各位玩家可以关注小杉果的持续报道。

数据库操作

asyncpg is the fastest driver among common Python, NodeJS and Go
implementations

运用asyncpg为数据库驱动, 对数据库连接举办打包, 执行数据库操作。

不应用ORM做数据库操作,一个缘由是性质,ORM会有性能的耗费,并且无法采用asyncpg高性能库。另一个是单个微服务是很简短的,表结构不会很复杂,简单的SQL语句就足以处理来,没必要引入ORM。使用peewee只是做模型设计

Example:

sql = "SELECT * FROM users WHERE name=$1"
name = "test"
async with request.app.db.acquire(request) as cur:
    data = await cur.fetchrow(sql, name)

async with request.app.db.transaction(request) as cur:
    data = await cur.fetchrow(sql, name)
  • acquire() 函数为非事务,
    对于只关乎到查询的利用非事务,可以增长查询效率
  • tansaction() 函数为工作操作,对于增删改必须拔取工作操作
  • 传扬request参数是为了获取到span,用于日志追踪
  • TODO 数据库读写分离

游戏还进入了地图标记功用,玩家在不可能赢得道具时方可先举办标记,等到拿到新力量后再回头尝试。

Swagger API

1514528294957.jpg

现年万圣节以内,育碧将为旗下玩耍荣耀战魂开启一项特别活动“异世界的国宴”(Feast
of the Otherworld)。

连带连接

swagger

和一般娱乐推出DLC骗钱被狂喷不同,玩家们纷纷为《棕色之城》打出了好评,DLC推出不到一天时间里积累评价84篇,好评则占到了72篇。游戏唯一的差评点似乎是新扩充包对mod的支撑并不到家,而非mod玩家则一心无需担心,可以购买游戏。

Response 数据

在回到时,不要回来sanic的response,直接重临原始数据,会在Middleware中对回到的数码开展处理,重临统一的格式,具体的格式可以[查看]

新情势下,占领目的点仅能获取200点临时点数奖励,要想让点数持续上升必须击杀敌方骷髅,这迫使玩家必须外出交战。

相关连接

opentracing
zipkin
jaeger

说到底还有理念最重大的事只好说,为了庆祝11 bit
studios和杉果家的协作,该发行商旗下全方位游戏将自前几天起在杉果起首优惠,感兴趣的玩家别忘了吃完午饭来看看啊~

类型地址

sanic-ms

Example

专门好评的银河城风格独立游戏《空洞骑士》在下一周三就要生产第二个免费扩张包“Grimm
Troupe”了。

有关连接

sanic

在《北美洲卡手模拟2》不断经过DLC扩充游戏领域的还要,《美利坚合众国卡内衣模特拟》也在增多新的区域,最新DLC中追加的“新墨西哥”就是内部之一。

服务端

动用sanic异步框架,有较高的性能,可是使用不当会造成blocking,
对于有IO请求的都要选拔异步库。添加库要慎重
sanic使用uvloop异步驱动,uvloop基于libuv使用Cython编写,性能比nodejs还要高。

效用表明:

5.《那是我的大战》厂商小说上架杉果并圆满让利,波兰独自游戏大举进军国内喽

连带连接

asyncpg
benchmarks

我们好!前天《荣耀战魂》开启了万圣节特别活动;《空洞骑士》第二个免费扩张包下周上线;《美利坚合众国卡服装模特拟》新墨西哥DLC发布;《城市:天际线-紫色之城》发售好评,体系折扣中;《这是自个儿的战乱》厂商游戏上架杉果,折扣同时拉开。

代码覆盖

coverage erase
coverage run --source . -m sanic_ms tests
coverage xml -o reports/coverage.xml
coverage2clover -i reports/coverage.xml -o reports/clover.xml
coverage html -d reports
  • coverage2colver 是将coverage.xml 转换成
    clover.xml,bamboo需要的格式是clover的。

赏心悦目战魂》方今在杉果有售,近日游乐以7.5折出售,售价186元,通过Uplay激活后仍可与Steam好友游玩。

相关连接

unittest
coverage

3.《弥利坚卡脚模拟》“新墨西哥”DLC发布

API接口

api文档使用swagger标准。

Example:

from sanic_ms import doc

@user_bp.post('/')
@doc.summary('create user')
@doc.description('create user info')
@doc.consumes(Users)
@doc.produces({'id': int})
async def create_user(request):
    data = request['data']
    async with request.app.db.transaction(request) as cur:
        record = await cur.fetchrow(
            """ INSERT INTO users(name, age, city_id, role_id)
                VALUES($1, $2, $3, $4, $5)
                RETURNING id
            """, data['name'], data['age'], data['city_id'], data['role_id']
        )
        return {'id': record['id']}
  • summary: api概要
  • description: 详细描述
  • consumes: request的body数据
  • produces: response的回来数据
  • tag: API标签
  • 在consumes和produces中传播的参数可以是peewee的model,会分析model生成API数据,
    在field字段的help_text参数来表示援引对象
  • http://host:ip/openapi/spec.json
    获取生成的json数据

1.《荣耀战魂》万圣节将翻开特别活动,小兵变骷髅

可怜处理

对抛出的相当举办处理,重回统一格式

甭管PC玩家如故手游玩家都很熟谙的生存游戏《这是自家的战事》前几天就要上架杉果了,一同上架的还有发行商11
bit studios的别样数款游戏,包括《Anomaly》类别和《Beat Cop》等创作。

任务

创造task消费queue中对span,用于日志追踪

《城市:天际线》的新扩大包“褐色之城”已经在前些天上线,该扩充包为游戏新增了汪洋环保核心建筑和绿化政策,以前已经把嬉戏探讨透彻的玩家们又有新情节可玩了。

Zipkin Server

1514528423339.jpg

1514528479787.jpg

依照惯例,特别节日的位移当然也会掉落特别奖励,比如专门的衣裳、表情、处决动画等。(疑似有神采中仍能放出Persona)

启动前

@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举行日志追踪

*关于“杉果游戏”:一家为国内单机玩家操碎了心的一日游代理发行平台。已与B社、卡普空、华纳、万代南梦宫等70余家中外厂商建立协作,致力于将生化危机、上古卷轴、辐射、蝙蝠侠、黑暗之魂等单机游戏带给中华玩家。*

日志 & 分布式追踪系统

利用官方logging, 配置文件为logging.yml,
sanic版本要0.6.0及以上。JsonFormatter将日志转成json格式,用于输入到ES

Enter OpenTracing: by offering consistent, expressive, vendor-neutral
APIs for popular platforms, OpenTracing makes it easy for developers
to add (or switch) tracing implementations with an O(1) configuration
change. OpenTracing also offers a lingua franca for OSS
instrumentation and platform-specific tracing helper libraries. Please
refer to the Semantic Specification.

Grimm Troupe没有品级或道具门槛,玩家可以在其它时刻探索这一职责线。

连带连接

aiohttp

“Grimm
Troupe”带来了一个全新的任务线,其中有新的boss、敌人和联盟登场,4个新的符文被投入到了游戏当中,此外还有一位据说可以为玩家们的剩余金钱找到用处的经纪人会出演。

分布式追踪系统

  • OpenTracing是以Dapper,Zipkin等分布式追踪系统为遵照,
    建立了联合的正规。
  • Opentracing跟踪每一个呼吁,记录请求所经过的每一个微服务,以链条的措施串联起来,对分析微服务的性质瓶颈至关紧要。
  • 利用opentracing框架,可是在出口时转换成zipkin格式。
    因为大多数分布式追踪系统考虑到性能问题,都是应用的thrift举办通信的,本着简便,Restful风格的旺盛,没有应用RPC通信。以日记的法子出口,
    可以接纳fluentd,
    logstash等日志收集再输入到Zipkin。Zipkin是支撑HTTP输入的。
  • 转变的span先无阻塞的放入queue中,在task中消费队列的span。前期可以添加上采样频率。
  • 对于DB,Client都加上了tracing

《荣耀战魂》”异世界的庆功宴“活动现已上线,九月2日前有爱的玩家可以为了特别掉落肝爆了。

特点

  • 利用sanic异步框架,简单,轻量,高效。
  • 运用uvloop为核心引擎,使sanic在成千上万场地下单机并发甚至不亚于Golang。
  • 使用asyncpg为数据库驱动,举办数据库连接,执行sql语句执行。
  • 利用aiohttp为Client,对任何微服务举行走访。
  • 运用peewee为ORM,但是只是用来做模型设计和migration。
  • 动用opentracing为分布式追踪系统。
  • 使用unittest做单元测试,并且接纳mock来避免访问其他微服务。
  • 利用swagger做API标准,能自动生成API文档。

按部就班规矩,《城市:天际线》的本体和后边推出的壮大包也在促销,游戏本体在杉果售价19元,比Steam国区22元的售价更是有益于。而娱乐在此以前生产的几款DLC也在打折中,往日还没上车的玩家可以考虑补上多少个好评扩张包了。

有关连接

peewee

客户端

选拔aiohttp中的client,对客户端举行了简便的卷入,用于微服务之间访问。

Don’t create a session per request. Most likely you need a session per
application which performs all requests altogether.
A session contains a connection pool inside, connection reusage and
keep-alives (both are on by default) may speed up total performance.

Example:

@app.listener('before_server_start')
async def before_srver_start(app, loop):
    app.client =  Client(loop, url='http://host:port')

async def get_role_by_id(request, id):
    cli = request.app.client.cli(request)
    async with cli.get('/cities/{}'.format(id)) as res:
        return await res.json()

@app.listener('before_server_stop')
async def before_server_stop(app, loop):
    app.client.close()

对于访问不同的微服务可以创建多少个例外的client,这样各类client都会keep-alives

装饰器logger

@logger(type='method', category='test', detail='detail', description="des", tracing=True, level=logging.INFO)
async def get_city_by_id(request, id):
    cli = request.app.client.cli(request)
  • type: 日志类型,如 method, route
  • category: 日志系列,默认为app的name
  • detail: 日志详细音讯
  • description: 日志描述,默认为函数的注脚
  • tracing: 日志追踪,默认为True
  • level: 日志级别,默认为INFO

发表评论

电子邮件地址不会被公开。 必填项已用*标注