用python为mysql实现restful接口
admin
2023-07-31 00:38:31
0

最近在做游戏服务分层的时候,一直想把mysql的访问独立成一个单独的服务DBGate,原因如下:

  1. 请求收拢到DBGate,可以使DBGate变为无状态的,方便横向扩展
  2. 当请求量或者存储量变大时,mysql需要做分库分表,DBGate可以内部直接处理,外界无感知
  3. 通过restful限制对数据请求的形式,仅支持简单的get/post/patch/put 进行增删改查,并不支持复杂查询。这个也是和游戏业务的特性有关,如果网站等需要复杂查询的业务,对此并不适合
  4. DBGate使用多进程模式,方便控制与mysql之间的链接数,进行mysql访问量阀值保护
  5. 方便在DBGate上进行访问量统计,慢查询统计、权限控制等等一系列逻辑
  6. 目前是使用python,以后要使用其他语言进行mysql操作时,只要进行标准的http请求即可,不会出现不兼容的情况

当然坏处也是有的:

  1. 首当其冲就是单次请求的响应时间变长,毕竟中间加了一层服务,并且还是http格式
  2. 部署上比原来复杂了一些,很多对mysql直接操作的思维需要进行转变,一开始可能会有些不适

不过总的来说,还是利大于弊,所以最终还是决定搭建DBGate

当然,我们不可能去手工挨个写每个库表对应的restful服务,值得庆幸的是django和flask都提供了对应的解决方案,我们一个个介绍.

Flask

参考链接: flask-restless

flask-restless使用方法比较简单,我直接贴一下代码即可:

12345678910111213141516171819202122232425262728 # -*- coding: utf-8 -*- import datetimefrom flask import Flaskfrom flask_sqlalchemy import SQLAlchemyfrom flask_restless import APIManager app = Flask(__name__)db = SQLAlchemy(app)restless = APIManager(app, flask_sqlalchemy_db=db) class User(db.Model):    \”\”\”    user    \”\”\”     id = db.Column(db.Integer, primary_key=True)    username = db.Column(db.String(255), unique=True, nullable=False)    password = db.Column(db.String(255), nullable=False)    create_time = db.Column(db.DateTime, nullable=False, default=datetime.datetime.utcnow)    login_time = db.Column(db.DateTime) restless.create_api(User, methods=[\’GET\’, \’POST\’, \’DELETE\’, \’PATCH\’, \’PUT\’], results_per_page=100) db.create_all() if __name__ == \’__main__\’:    app.run(port=25000)

 

其对应的restful操作如下:

12345 获取用户列表:   GET /user添加用户:       POST /user获取单个用户:   GET /user/1覆盖单个用户:   PUT /user/1修改单个用户:   PATCH /user/1

 

注意:

  1. 在http请求中,记得加入header: Content-Type: application/json
  2. flask-restless中,PUT和PATCH一样,都是传入什么字段,只修改什么字段,不会完全覆盖

Django

参考链接: Django REST framework

Django用起来要更复杂一些,也因为django版自带了一个可视化的操作页面,如下:

QQ20140803 2

1. 在settings中添加:

12345678910111213 REST_FRAMEWORK = {    # Use hyperlinked styles by default.    # Only used if the `serializer_class` attribute is not set on a view.    \’DEFAULT_MODEL_SERIALIZER_CLASS\’:        \’rest_framework.serializers.HyperlinkedModelSerializer\’,     # Use Django\’s standard `django.contrib.auth` permissions,    # or allow read-only access for unauthenticated users.    \’DEFAULT_PERMISSION_CLASSES\’: [        #\’rest_framework.permissions.DjangoModelPermissionsOrAnonReadOnly\’,        \’rest_framework.permissions.IsAdminUser\’,    ]}

2. 通过startapp建立一个app: demo

3. 修改demo的models:

12345 class User(models.Model):    # key是保留字    password = models.IntegerField()    nick = models.CharField(max_length=255)    create_time = models.DateTimeField(default=datetime.\”crayon-v\”>create_time = models.DateTimeField(default=datetime.BGate可以内部直接处理,外界无感知

  • 通过restful限制对数据请求的形式,仅支持简单的get/post/patch/put 进行增删改查,并不支持复杂查询。这个也是和游戏业务的特性有关,如果网站等需要复杂查询的业务,对此并不适合
  • DBGate使用多进程模式,方便控制与mysql之间的链接数,进行mysql访问量阀值保护
  • 方便在DBGate上进行访问量统计,慢查询统计、权限控制等等一系列逻辑
  • 目前是使用python,以后要使用其他语言进行mysql操作时,只要进行标准的http请求即可,不会出现不兼容的情况
  • 当然坏处也是有的:

    1. 首当其冲就是单次请求的响应时间变长,毕竟中间加了一层服务,并且还是http格式
    2. 部署上比原来复杂了一些,很多对mysql直接操作的思维需要进行转变,一开始可能会有些不适

    不过总的来说,还是利大于弊,所以最终还是决定搭建DBGate

    当然,我们不可能去手工挨个写每个库表对应的restful服务,值得庆幸的是django和flask都提供了对应的解决方案,我们一个个介绍.

    Flask

    参考链接: flask-restless

    flask-restless使用方法比较简单,我直接贴一下代码即可:

    12345678910111213141516171819202122232425262728 # -*- coding: utf-8 -*- import datetimefrom flask import Flaskfrom flask_sqlalchemy import SQLAlchemyfrom flask_restless import APIManager app = Flask(__name__)db = SQLAlchemy(app)restless = APIManager(app, flask_sqlalchemy_db=db) class User(db.Model):    \”\”\”    user    \”\”\”     id = db.Column(db.Integer, primary_key=True)    username = db.Column(db.String(255), unique=True, nullable=False)    password = db.Column(db.String(255), nullable=False)    create_time = db.Column(db.DateTime, nullable=False, default=datetime.datetime.utcnow)    login_time = db.Column(db.DateTime) restless.create_api(User, methods=[\’GET\’, \’POST\’, \’DELETE\’, \’PATCH\’, \’PUT\’], results_per_page=100) db.create_all() if __name__ == \’__main__\’:    app.run(port=25000)

     

    其对应的restful操作如下:

    12345 获取用户列表:   GET /user添加用户:       POST /user获取单个用户:   GET /user/1覆盖单个用户:   PUT /user/1修改单个用户:   PATCH /user/1

     

    注意:

    1. 在http请求中,记得加入header: Content-Type: application/json
    2. flask-restless中,PUT和PATCH一样,都是传入什么字段,只修改什么字段,不会完全覆盖

    Django

    参考链接: Django REST framework

    Django用起来要更复杂一些,也因为django版自带了一个可视化的操作页面,如下:

    QQ20140803 2

    1. 在settings中添加:

    12345678910111213 REST_FRAMEWORK = {    # Use hyperlinked styles by default.    # Only used if the `serializer_class` attribute is not set on a view.    \’DEFAULT_MODEL_SERIALIZER_CLASS\’:        \’rest_framework.serializers.HyperlinkedModelSerializer\’,     # Use Django\’s standard `django.contrib.auth` permissions,    # or allow read-only access for unauthenticated users.    \’DEFAULT_PERMISSION_CLASSES\’: [        #\’rest_framework.permissions.DjangoModelPermissionsOrAnonReadOnly\’,        \’rest_framework.permissions.IsAdminUser\’,    ]}

    2. 通过startapp建立一个app: demo

    3. 修改demo的models:

    12345 class User(models.Model):    # key是保留字    password = models.IntegerField()    nick

    相关内容

    热门资讯

    Mobi、epub格式电子书如... 在wps里全局设置里有一个文件关联,打开,勾选电子书文件选项就可以了。
    500 行 Python 代码... 语法分析器描述了一个句子的语法结构,用来帮助其他的应用进行推理。自然语言引入了很多意外的歧义,以我们...
    定时清理删除C:\Progra... C:\Program Files (x86)下面很多scoped_dir开头的文件夹 写个批处理 定...
    scoped_dir32_70... 一台虚拟机C盘总是莫名奇妙的空间用完,导致很多软件没法再运行。经过仔细检查发现是C:\Program...
    65536是2的几次方 计算2... 65536是2的16次方:65536=2⁶ 65536是256的2次方:65536=256 6553...
    小程序支付时提示:appid和... [Q]小程序支付时提示:appid和mch_id不匹配 [A]小程序和微信支付没有进行关联,访问“小...
    pycparser 是一个用... `pycparser` 是一个用 Python 编写的 C 语言解析器。它可以用来解析 C 代码并构...
    微信小程序使用slider实现... 众所周知哈,微信小程序里面的音频播放是没有进度条的,但最近有个项目呢,客户要求音频要有进度条控制,所...
    Apache Doris 2.... 亲爱的社区小伙伴们,我们很高兴地向大家宣布,Apache Doris 2.0.0 版本已于...
    python清除字符串里非数字... 本文实例讲述了python清除字符串里非数字字符的方法。分享给大家供大家参考。具体如下: impor...