Как получить доступ к данным JSON POST в приложении Flask RESTful API

В настоящее время я застрял, пытаясь получить доступ к данным POST json в приложении flask RESTful API. Данные POST — это просто кадр данных Pandas, преобразованный в объект json с помощью метода pandas.to_json().

import pandas as pd
from flask import Flask, request, jsonify
from flask_restful import Resource, Api


app = Flask(__name__)
api = Api(app)

# Creation Of Main Endpoint Classes
class Test(Resource):
    def post(self):

        # Get POST data as json & read it as a DataFrame
        new_x = request.get_json()

        current_data = pd.read_json(new_x)
        return {'message': 'POST data read successfully'}

# Addition of the Endpoint Classes As Endpoints For The RESTFul API
api.add_resource(Test, '/api/v1')


if __name__ == '__main__':
    app.run(debug=True)

После выполнения запроса POST к этой конечной точке теста я получаю ошибку JSONDecodeError: Expecting value. Пост сделан с запросами библиотеки python как:

import requests
new_json = df.to_json()
post_url = 'http://127.0.0.1:5000/api/v1'
post_r = requests.post(url=post_url, data=new_json_orient)
print(post_r.json())

Трассировка стека, кажется, указывает на то, что request.get_json() возвращает None с <class 'NoneType'>. Панды, в результате, не могут читать None. Pandas и я упускаем расположение данных POST.

127.0.0.1 - - [08/Mar/2019 13:06:56] "POST /api/v1 HTTP/1.1" 500 -
Traceback (most recent call last):
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\app.py", line 2309, in __call__
    return self.wsgi_app(environ, start_response)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\app.py", line 2295, in wsgi_app
    response = self.handle_exception(e)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask_restful\__init__.py", line 273, in error_router
    return original_handler(e)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\app.py", line 1741, in handle_exception
    reraise(exc_type, exc_value, tb)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\_compat.py", line 34, in reraise
    raise value.with_traceback(tb)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\app.py", line 2292, in wsgi_app
    response = self.full_dispatch_request()
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\app.py", line 1815, in full_dispatch_request
    rv = self.handle_user_exception(e)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask_restful\__init__.py", line 273, in error_router
    return original_handler(e)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\app.py", line 1718, in handle_user_exception
    reraise(exc_type, exc_value, tb)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\_compat.py", line 34, in reraise
    raise value.with_traceback(tb)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\app.py", line 1813, in full_dispatch_request
    rv = self.dispatch_request()
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\app.py", line 1799, in dispatch_request
    return self.view_functions[rule.endpoint](**req.view_args)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask_restful\__init__.py", line 480, in wrapper
    resp = resource(*args, **kwargs)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask\views.py", line 88, in view
    return self.dispatch_request(*args, **kwargs)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\flask_restful\__init__.py", line 595, in dispatch_request
    resp = meth(*args, **kwargs)
  File "C:\Users\..\Documents\..\app.py", line 35, in post
    current_data = pd.read_json(new_x)
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\pandas\io\json\json.py", line 413, in read_json
    path_or_buf, encoding=encoding, compression=compression,
  File "C:\Users\..\AppData\Local\Continuum\anaconda3\envs\..\lib\site-packages\pandas\io\common.py", line 232, in get_filepath_or_buffer
    raise ValueError(msg.format(_type=type(filepath_or_buffer)))
ValueError: Invalid file path or buffer object type: <class 'NoneType'>

Что я делаю не так? Как я могу получить доступ к данным POST new_json? Заранее спасибо.


person Mysterio    schedule 08.03.2019    source источник
comment
В какой момент вы получаете эту ошибку? При разборе ответа (post_r.json()) или преобразовании запроса в json (request.get_json())? Полная трассировка стека действительно не оставила бы места для этого комментария.   -  person vahdet    schedule 08.03.2019
comment
@vahdet Я отредактирую вопрос с трассировкой. Я получаю это в request.get_json().   -  person Mysterio    schedule 08.03.2019


Ответы (1)


Скорее всего, это связано с тем, что метод POST не содержит никакой информации для Content-Type этого метода.

  1. Если версия requests новее 2.4.2, вы можете использовать json вместо data для тела сообщения (см. детали документа здесь). Это автоматически установит заголовок 'Content-Type': 'application/json':
post_r = requests.post(url=post_url, json=new_json_orient)
  1. Если запросы вашего использования старше, вы можете явно установить значение заголовка как:
headers = {'Content-type': 'application/json'}
post_r = requests.post(url=post_url, data=new_json_orient, headers=headers)

P.S. Чтобы узнать больше о заголовке Content-Type, который так часто упоминается в этом посте, перейдите по ссылке документы MDN.

person vahdet    schedule 08.03.2019
comment
Оно работает! Переключение с данных на json помогло. Я твой должник! - person Mysterio; 08.03.2019