Как в FastAPI вернуть StreamingResponse, а также сделать что-нибудь после завершения потоковой передачи?

В моем маршруте FastAPI мне нужно вернутьпользователю по мере генерации каждого фрагмента текстового предложения.

Однако полное текстовое предложение необходимо вставить в базу данных. Есть ли способ сделать это?

      @app.post("/foo_stream")
def foo_stream(input: Input, db: Session = Depends(get_db)):
    return StreamingResponse(
        generate_streaming_response(input),
        media_type="text/plain",
    )

    # Now that the streaming is done, how do you insert the entire text into our database?

0 ответов

Другие вопросы по тегам