Python3 .8 - FastAPI и Serverless (AWS Lambda) - Невозможно обрабатывать файлы, отправленные на конечную точку api - PullRequest
Новая
       110

Python3 .8 - FastAPI и Serverless (AWS Lambda) - Невозможно обрабатывать файлы, отправленные на конечную точку api

0 голосов
/ 07 мая 2020

Я использую FastAPI с бессерверными функциями через AWS Lambda в течение нескольких месяцев, и он работает отлично.

Я создаю новую конечную точку api, для которой требуется отправить один файл.

Он отлично работает при использовании на моем локальном компьютере, но при развертывании на AWS Lambda у меня возникает следующая ошибка, когда я пытаюсь вызвать свою конечную точку с тем же файлом, который работает локально. Я делаю это сейчас в качестве теста через пользовательский интерфейс swagger, и ничего не меняется между моим бессерверным или моим локальным компьютером, кроме «машины», на которой выполняется код.

Вы хоть представляете, что происходит на?

Python 3.8 FastAPI 0.54.1

Мой код: 

from fastapi import FastAPI, File, UploadFile
import pandas as pd

app = FastAPI()

@app.post('/process_data_import_quote_file')
def process_data_import_quote_file(file: UploadFile = File(...)): # same error if I put bytes instead of UploadFile
    file = file.file.read()
    print(f"file {file}")
    quote_number = pd.read_excel(file, sheet_name='Data').iloc[:, 0].dropna()

Не работает на последней строке

Я пробовал Чтобы распечатать файл, когда я сравниваю напечатанные данные с тем, что я читаю локально, это другое. Клянусь, это тот же файл, который я использую на 2, поэтому я не знаю, чем это объяснить? Это очень простой c файл Excel, ничего особенного. 

[ERROR] 2020-05-07T14:25:17.878Z    25ff37a5-e313-4db5-8763-1227e8244457    Exception in ASGI application

Traceback (most recent call last):
  File "/var/task/mangum/protocols/http.py", line 39, in run
    await app(self.scope, self.receive, self.send)
  File "/var/task/fastapi/applications.py", line 149, in __call__
    await super().__call__(scope, receive, send)
  File "/var/task/starlette/applications.py", line 102, in __call__
    await self.middleware_stack(scope, receive, send)
  File "/var/task/starlette/middleware/errors.py", line 181, in __call__
    raise exc from None
  File "/var/task/starlette/middleware/errors.py", line 159, in __call__
    await self.app(scope, receive, _send)
  File "/var/task/starlette/exceptions.py", line 82, in __call__
    raise exc from None
  File "/var/task/starlette/exceptions.py", line 71, in __call__
    await self.app(scope, receive, sender)
  File "/var/task/starlette/routing.py", line 550, in __call__
    await route.handle(scope, receive, send)
  File "/var/task/starlette/routing.py", line 227, in handle
    await self.app(scope, receive, send)
  File "/var/task/starlette/routing.py", line 41, in app
    response = await func(request)
  File "/var/task/fastapi/routing.py", line 196, in app
    raw_response = await run_endpoint_function(
  File "/var/task/fastapi/routing.py", line 150, in run_endpoint_function
    return await run_in_threadpool(dependant.call, **values)
  File "/var/task/starlette/concurrency.py", line 34, in run_in_threadpool
    return await loop.run_in_executor(None, func, *args)
  File "/var/lang/lib/python3.8/concurrent/futures/thread.py", line 57, in run
    result = self.fn(*self.args, **self.kwargs)
  File "/var/task/app/quote/processing.py", line 100, in process_data_import_quote_file
    quote_number = pd.read_excel(file, sheet_name='Data').iloc[:, 0].dropna()
  File "/var/task/pandas/io/excel/_base.py", line 304, in read_excel
    io = ExcelFile(io, engine=engine)
  File "/var/task/pandas/io/excel/_base.py", line 821, in __init__
    self._reader = self._engines[engine](self._io)
  File "/var/task/pandas/io/excel/_xlrd.py", line 21, in __init__
    super().__init__(filepath_or_buffer)
  File "/var/task/pandas/io/excel/_base.py", line 355, in __init__
    self.book = self.load_workbook(BytesIO(filepath_or_buffer))
  File "/var/task/pandas/io/excel/_xlrd.py", line 34, in load_workbook
    return open_workbook(file_contents=data)
  File "/var/task/xlrd/__init__.py", line 115, in open_workbook
    zf = zipfile.ZipFile(timemachine.BYTES_IO(file_contents))
  File "/var/lang/lib/python3.8/zipfile.py", line 1269, in __init__
    self._RealGetContents()
  File "/var/lang/lib/python3.8/zipfile.py", line 1354, in _RealGetContents
    fp.seek(self.start_dir, 0)
ValueError: negative seek value -62703616

1 Ответ

2 голосов
/ 08 мая 2020

это произошло из-за AWS API Gateway. Мне пришлось разрешить multipart / form-data в API Gateway и исправить с помощью file = BytesIO (file) .read (), чтобы иметь возможность правильно использовать файловый поток.

...