用 Bottle 处理 application/json 数据

Question

我正在尝试使用基于 Restful JSON 的协议向 python3 应用程序编写一个简单的服务器前端。到目前为止， bottle 似乎是最适合该任务的框架（它支持 python3，以一种很好的方式处理方法分派，并且很容易返回 JSON。）问题是解析输入请求中的 JSON。

该文档仅提到 request.fields 和 request.files ，我认为两者都指的是 multipart/form-data 数据。没有提到直接访问请求数据。

查看源代码，我可以看到一个 BytesIO 类型的 request.body 对象。 json.load 拒绝直接对其进行操作，在 json 库中因 can't use a string pattern on a bytes-like object 而死掉。正确的方法可能是首先根据 Content-Type HTTP 标头中指定的字符集将字节解码为 un​​icode 字符。我不知道该怎么做；我可以看到一个 StringIO 类，并假设它可能保存一个字符缓冲区而不是字节，但看不到将 BytesIO 解码为 StringIO 的方法，如果这甚至可能的话。

当然，也可以将 BytesIO 对象读入字节串，然后将其解码为字符串，然后将其传递给 JSON 解码器，但如果我理解正确的话，这会破坏整个事物的良好缓冲行为。

或者有什么更好的方法吗？

Answer 1

似乎标准中的 io.TextIOWrapper图书馆就可以解决这个问题！

def parse(request):
    encoding = ... #get encoding from headers
    return json.load(TextIOWrapper(request.body, encoding=encoding))

Answer 2

正如评论中提到的（以及类似的答案)，request.json 方法从 Bottle 0.1.0 开始可用。

所以就像：

@route('/endpoint', method='POST')
def parse():
    body = request.json
    name = body.get('name')
    age = body.get('age')

Answer 3

以下是我使用 Python3 和 Bottle 在 RESTful 服务上读取 json 的操作：

import bson.json_util as bson_json

@app.post('/location/API')
def post_json_example():
    """
    param: _id, value
    return: I usually return something like {"status": "successful", "message": "discription"}
    """

    query_string = bottle.request.query.json
    query_dict = bson_json.loads(query_string)
    _id = query_dict['_id']
    value = query_dict['value']

然后从 python3 解释器进行测试

• ，导入 requests
• s = request.Session()
• r = s.post('http://youserver.com:8080/location/API?json
  {"_id":"540a16663dafb492a0a7626c","value":"test"}')
• 使用 r.text 来验证返回的内容。

Answer 4

我写了一个助手来使用 b0fh 的好主意。
经过 2 周的 response.json 分析后，我连接到 StackOver Flow 并了解到我们需要解决

以下问题：

def json_app_rqt():
    # about request
    request.accept = 'application/json, text/plain; charset=utf-8'

def json_app_resp():
    # about response
    response.headers['Access-Control-Allow-Origin'] = _allow_origin
    response.headers['Access-Control-Allow-Methods'] = _allow_methods
    # response.headers['Access-Control-Allow-Headers'] = _allow_headers
    response.headers['Content-Type'] = 'application/json; charset=utf-8'

def json_app():
    json_app_rqt()
    json_app_resp()

def get_json_request(rqt):
    with TextIOWrapper(rqt.body, encoding = "UTF-8") as json_wrap:
        json_text = ''.join(json_wrap.readlines())
        json_data = json.loads(json_text)
        return json_data

对于使用，我们可以做：

if __name__ == "__main__":

    json_app()

    @post("/train_control/:control")
    def do_train_control(control):
        json_app_resp()

        data = get_json_request(request)
        print(json.dumps(data))

        return data

感谢所有人