从fastapi返回多个文件
，可以通过使用Streaming Response来实现。Streaming Response是FastAPI中的一个响应类，它允许我们将数据流式传输到客户端。
以下是实现该功能的步骤：
- 导入必要的模块和类：
from fastapi import FastAPI
from fastapi.responses import StreamingResponse- 创建一个FastAPI应用：
app = FastAPI()- 定义一个路由，用于处理返回多个文件的请求：
@app.get("/multiple_files")
async def get_multiple_files():
# 生成多个文件的数据
file1_data = b"File 1 Data"
file2_data = b"File 2 Data"
# 创建一个生成器函数，用于逐个生成文件数据
def generate_files():
yield file1_data
yield file2_data
# 使用StreamingResponse将文件数据流式传输到客户端
return StreamingResponse(generate_files(), media_type="application/octet-stream")在上述代码中，我们定义了一个GET请求的路由/multiple_files，当客户端发送该请求时，会生成两个文件的数据，并使用StreamingResponse将文件数据流式传输到客户端。generate_files()函数是一个生成器函数，通过yield关键字逐个生成文件数据。
- 运行FastAPI应用：
if __name__ == "__main__":
uvicorn.run(app, host="0.0.0.0", port=8000)现在，当访问http://localhost:8000/multiple_files时，将会返回两个文件的数据流。
这种方法适用于需要返回多个文件的场景，例如批量下载、打包下载等。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos
- 腾讯云CDN加速：https://cloud.tencent.com/product/cdn
- 腾讯云云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 腾讯云容器服务（TKE）：https://cloud.tencent.com/product/tke
- 腾讯云函数计算（SCF）：https://cloud.tencent.com/product/scf
相关·内容
我需要通过FastAPI发送文件和数据。我试着发送请求，但没能让它起作用
例如：
服务器：
import uvicorn
from fastapi import FastAPI, File
from pydantic import BaseModel
app = FastAPI()
class Data(BaseModel):
test1: str = None
test2: str = None
test3: str = None
@app.post("/uploadfile/")
async def create_file(
da
浏览 2提问于2021-10-02得票数 2
回答已采纳
我想知道如何使用DataFrame来流FastAPI，而不必将DataFrame保存到磁盘上的csv文件中。目前，我所做的是从csv文件中流数据，但是与返回FileResponse相比速度并不快。下面的/option7是我想要做的。
我的目标是从FastAPI后端流数据，而不将DataFrame保存到csv文件中。
谢谢。
from fastapi import FastAPI, Response,Query
from fastapi.responses import FileResponse,HTMLResponse,StreamingResponse
app = FastAPI()
df
浏览 12提问于2022-09-12得票数 1
回答已采纳
具体来说，我希望下面的例子能够奏效：
from typing import List
from pydantic import BaseModel
from fastapi import FastAPI, UploadFile, File
app = FastAPI()
class DataConfiguration(BaseModel):
textColumnNames: List[str]
idColumn: str
@app.post("/data")
async def data(dataConfiguration: DataConfigur
浏览 8提问于2020-12-30得票数 17
错误消息如下：
GET 404 (未找到)
除了下面代码中的@app.get("/api") 请求之外，它的工作性能很好。我使用Node.js(Express)尝试了类似的功能，它运行得很好。
我是否需要将API服务器与分发静态文件的服务器(与Node.js不同)分开？
from fastapi import FastAPI
from fastapi.staticfiles import StaticFiles
from fastapi.responses import FileResponse
from fastapi import FastAPI
import uvi
浏览 2提问于2022-10-08得票数 0
我将创建一个将html转换为PDF文件的api。我是用pdfkit和fastapi做的。但它会将文件保存到我的本地主机。我在网上提供此api后，用户如何将此PDF文件下载到他们的计算机上。 from typing import Optional
from fastapi import FastAPI
import pdfkit
app = FastAPI()
@app.post("/htmltopdf/{url}")
def convert_url(url:str):
pdfkit.from_url(url, 'converted.pdf')
浏览 35提问于2020-10-23得票数 1
回答已采纳
2回答
有没有办法通过FastAPI下载文件？我们想要的文件位于Azure Datalake中，从湖中检索它们不是问题，当我们试图从datalake中获取字节到本地机器时，问题就会发生。 我们尝试过在FastAPI中使用不同的模块，比如starlette.responses.FileResponse和fastapi.Response，但都没有成功。 在Flask中，这不是问题，可以通过以下方式完成： from io import BytesIO
from flask import Flask
from werkzeug import FileWrapper
flask_app = Flask(__
浏览 33提问于2020-09-14得票数 0
回答已采纳
我正在开始使用Azure应用程序服务。
我跟踪了，并能够让main.py应用程序运行。
模块(fastapi，uvicorn等.)requirements.txt中指定的所有安装和导入都是正确的。
然而，当试图导入位于与main.py相同的目录中的Python文件时，部署仍然是成功的，但是当我试图通过网页浏览时，我得到了一个应用程序错误：
例如，我创建了一个名为settings.py，的文件，该文件包含：
MY_TITLE = "My FastAPI prototype"
在这个中，我简单地修改了：
app = FastAPI()
通过以下方式：
import setti
浏览 7提问于2022-09-04得票数 1
回答已采纳
我试图通过一些用FastAPI构建的简单FastAPI(使用uvicorn)将一些json内容从客户机传递到服务器。如果我将文件内容包装到pydantic.BaseModel中，如下所示
app = FastAPI()
class ConfigContents(BaseModel):
str_contents: str
@app.post("/writeFile/{fn}")
async def write_file(fn: str, contents: ConfigContents):
filepath = "/some_server_dir/&#
浏览 17提问于2021-01-11得票数 0
回答已采纳
1回答
我正在尝试使用FASTAPI从雪花数据库中读取数据。我能够创建一个连接，它能够从雪花中提取数据。
我现在面临的问题是，我只拿到一张唱片(而不是十张唱片)。我怀疑我在返回数据时没有使用正确的关键字。感谢你的帮助。
这是我的密码:-
from fastapi import FastAPI
import snowflake.connector as sf
import configparser
username='username_value'
password='password_value'
account= 'account_value'
w
浏览 5提问于2022-01-24得票数 0
回答已采纳
我正在尝试创建一个FastAPI端点，用户可以在其中上传json格式或gzip文件格式的文档。我可以让端点单独/单独地从这两个方法接收数据，但不能在一个端点/函数中一起接收数据。有没有办法让同一个FastAPI端点接收json或文件？
json示例：
from fastapi import FastAPI
from pydantic import BaseModel
class Document(BaseModel):
words: str
app = FastAPI()
@app.post("/document/")
async def create_it
浏览 0提问于2020-12-17得票数 3
我试图使用graphql和Fastapi + StrawBerry从Rick&Morty的api中获取字符字段，而且我编写的第一个字段总是有相同的错误
我的代码：
from fastapi import FastAPI
import strawberry
from strawberry.fastapi import GraphQLRouter
import requests
@strawberry.type
class Character:
id: int
name: str
status: str
species: str
@strawberry.
浏览 9提问于2022-11-05得票数 1
回答已采纳
我在dockerCompose.yml中有一个特定的服务，名为‘specific’，它基于fastAPI python包。
fastapi:
image: fastapi
labels:
- "traefik.frontend.rule=PathPrefixStrip:/fastapi"
- traefik.port=5000
volumes:
- ./fastapi:/app
- ./data:/data
通过localhost/fast
浏览 0提问于2019-08-22得票数 0
1回答
我想更好地理解gunicorn是如何管理它的进程的，所以我写了下面的代码：
from fastapi import FastAPI
import os
from time import sleep
app = FastAPI()
sleep_time = [5, 0]
global_var = 100
order_called = 0
@app.get('/test')
def test_handler():
global global_var, order_called
order_called += 1
local_order_c
浏览 20提问于2020-05-30得票数 0
因此，我正在学习FastAPI，并试图弄清楚如何正确地返回状态码。我做了一个上传文件的端点，我想在文件格式不受支持的情况下做出特殊的响应。似乎我按照official documentation做了所有的事情，但是我总是收到422 Unprocessable Entity错误。 下面是我的代码： from fastapi import FastAPI, File, UploadFile, status
from fastapi.openapi.models import Response
app = FastAPI()
@app.post('/upload_file/',
浏览 14提问于2021-07-06得票数 2
回答已采纳
我必须为一个向其他API发送多个请求并将它们的响应合并为输出的API提供服务。
实现这一目标的最佳方式是什么？这是某种异步等待场景吗？感谢你的建议。
from fastapi import FastAPI
import requests
app = FastAPI()
@app.post('/api')
def main_api():
JScontent = json.loads(request.json())
input = JScontent['content']
response1 = requests.post(url1, j
浏览 1提问于2021-04-17得票数 2
您好，我正在尝试链接到一个json文件从html代码使用fastapi和jinja2，但链接不起作用。我想我必须告诉fastapi如何找到文件或类似的东西..我得到了文件的json (api)应答instad。 {"detail":"Not Found"} python代码： from fastapi import FastAPI, Form, Request
from fastapi.responses import HTMLResponse
from fastapi.templating import Jinja2Templates
app = Fast
浏览 49提问于2021-01-28得票数 0
回答已采纳
1回答
我正在开发一个API，它从本地文件夹返回一些文件，以模拟开发人员环境中的系统。
大多数系统的工作方式是将识别人员的代码放入并返回他的文件。但是，这个系统的一条路径有一个独特的行为:它使用POST方法(请求主体包含Id代码)，我正在努力使它工作。
这是我目前的代码：
import json
from pathlib import Path
import yaml
from fastapi import FastAPI
from pydantic.main import BaseModel
app = FastAPI()
class RequestModel(BaseModel):
浏览 1提问于2021-01-11得票数 4
回答已采纳
我正在构建一个FastAPI端点，web客户端用户实际上可以下载文件，这些文件以GridFS块的形式存储在MongoDB中。但是，FastAPI的StreamingResponse没有接受motor的open_download_stream方法返回的假定类似文件的AsyncIOMotorGridOut对象。 我已经有了一个端点，它可以获取表单中的文件并将它们上传到MongoDB。我希望一个类似的下载助手函数能像下面这样简单： async def upload_file(db, file: UploadFile):
""" Uploads file to Mon
浏览 155提问于2021-01-24得票数 1
回答已采纳
我的模板如下：
<!-- template1.html -->
<html>
<head>
<title>Item Details</title>
</head>
<body>
<p>{{ req }}</p>
</body>
</html>
为了呈现模板，我使用以下代码：
from fastapi import FastAPI
from fastapi.templating import Jinja2Templates
app = FastAP
浏览 7提问于2022-08-11得票数 0
我想在FastApi上有一个动态的强制机构。
我解释：
from fastapi import FastAPI, Body
from pydantic import BaseModel
app = FastAPI()
class Parameters(BaseModel):
platform: str
country: str
@app.put("/myroute")
async def provision_instance(*, parameters: Parameters = Body(...)):
do_something
if __nam
浏览 1提问于2020-03-26得票数 1
目前，我正在为FastAPI和文件服务而挣扎。
在我的项目中，我有以下工作流。客户端发送包含必要有效负载的有效负载，以便从第三方提供程序下载文件。
我需要向后端发送一个有效负载，这是必要的，而且由于创建了一个资源(下载的文件)，我假设POST将是这个端点的方法，但让我给您展示一个示例。
from fastapi import FastAPI, Form
from fastapi.responses import FileResponse
import os
app = FastAPI()
@app.post("/download_file")
async def do
浏览 3提问于2021-04-15得票数 3
回答已采纳
我使用了从上传视频文件的代码，但是出现了一个错误。
这是从相册中选择视频的代码：
var videoURL: URL?
extension ViewController: UIImagePickerControllerDelegate, UINavigationControllerDelegate {
func imagePickerController(_ picker: UIImagePickerController, didFinishPickingMediaWithInfo info: [UIImagePickerController.InfoKey : Any]) {
浏览 4提问于2022-04-28得票数 1
我想创建一个模块化的应用程序，其中不同的子API将可用。这些API可以通过配置来启用/禁用。 下面是他们的文档中显示的FastAPI示例： from fastapi import FastAPI
app = FastAPI()
@app.get("/app")
def read_main():
return {"message": "Hello World from main app"}
subapi = FastAPI()
@subapi.get("/sub")
def read_sub():
ret
浏览 53提问于2021-10-18得票数 0
回答已采纳
当我试图从端点'data'访问'/'变量时，会得到以下错误。
ValueError: [ValueError('dictionary update sequence element #0 has length 1; 2 is required'), TypeError('vars() argument must have __dict__ attribute')]
代码：
from fastapi import FastAPI
app = FastAPI()
data = {}
@app.on_event("startup
浏览 9提问于2022-02-25得票数 2
我有一些问题通过FastAPI插入到FastAPI中。
下面的代码按预期工作。注意response变量在response_to_mongo()中是如何没有被使用的。
model是一种滑雪ElasticNet模型。
app = FastAPI()
def response_to_mongo(r: dict):
client = pymongo.MongoClient("mongodb://mongo:27017")
db = client["models"]
model_collection = db["example-mode
浏览 30提问于2022-03-14得票数 2
回答已采纳
这是我第一次在python开发中使用VSCode，我遇到了一些问题，我不知道为什么。
眼前的问题是，我似乎无法让uvicorn将我的浏览器请求路由到我的fastAPI模块。下面是我代码的相关部分：
import uvicorn
from fastapi import FastAPI, Header, HTTPException, Request, status, Response
from fastapi.middleware.cors import CORSMiddleware
from fastapi.responses import JSONResponse
from pydantic
浏览 25提问于2022-04-13得票数 0
回答已采纳
我想编写一个从脚本启动的最小FastAPI静态文件服务器，该脚本允许您指定要在命令行上共享的目录。在之后，我写了这个。
import uvicorn
from fastapi import FastAPI
from fastapi.staticfiles import StaticFiles
server = FastAPI()
if __name__ == "__main__":
import sys
directory = sys.argv[1]
server.mount("/static", StaticFiles(direc
浏览 14提问于2022-11-23得票数 0
回答已采纳
5回答
我可能没有正确理解FastAPI中的异步概念。
我同时从两个客户端访问以下应用程序的根端点。我希望FastAPI在执行开始时连续两次打印Started：
from fastapi import FastAPI
import asyncio
app = FastAPI()
@app.get("/")
async def read_root():
print('Started')
await asyncio.sleep(5)
print('Finished')
return {"Hello": &#
浏览 8提问于2019-10-14得票数 12
回答已采纳
我使用FastAPI & Jinja2来提供一个HTML页面来上传一个图像文件，然后打开另一个带有上传图像名的HTML链接来显示该图像。尽管我能够让上传部分和上传的图像链接正常工作，但我无法让src标记实际显示图像。我怎么能解决这个问题？
我是main.py
from fastapi import FastAPI, File, UploadFile,Request
from fastapi.responses import HTMLResponse
from fastapi.staticfiles import StaticFiles
from fastapi.templating
浏览 18提问于2022-08-06得票数 1
回答已采纳
我有一个FastAPI应用程序，它返回一个HTMLResponse。代码简单明了，如FastAPI的中的示例所示。响应工作正常，但是Swagger显示原始的HTML内容。有办法显示实际的HTML页面吗？
from fastapi import FastAPI
from fastapi.responses import HTMLResponse
app = FastAPI()
@app.get("/items/")
async def read_items():
html_content = """
<html>
浏览 13提问于2022-11-11得票数 1
我正在尝试创建一个API函数，它接受.csv文件(上传)并以熊猫DataFrame的形式打开它。就像这样：
from fastapi import FastAPI
from fastapi import UploadFile, Query, Form
import pandas as pd
app = FastAPI()
@app.post("/check")
def foo(file: UploadFile):
df = pd.read_csv(file.file)
return len(df)
然后，我调用我的API：
import requests
浏览 9提问于2022-05-21得票数 1
回答已采纳
我使用这个来保护我的fastapi应用程序中的端点。它似乎运行得很好，我还可以运行一些测试(使用pytest)：
...
client = TestClient(app=app)
response = client.post(
"/my_end_point",
json={'data':'model'},
headers={"Authorization": f"Bearer {token}"},
)
...
我的问题是，我想将我
浏览 0提问于2021-09-17得票数 1
回答已采纳
我正在尝试在FastAPI上加载一个经过训练的模型，并尝试从笔记本上点击它(以模拟前端调用)。但是，如果说模型文件不存在，则会不断出错。我对此很陌生，任何建议都欢迎.
培训笔记本： model.save('/data/model')
下载了模型并将整个文件夹放在FastAPI文件夹中。
文件结构的FastAPI:
>> API
>> _pycache_
>> model
>> assets
>> variables
keras_metadata.pb
saved_model.pb
浏览 0提问于2021-06-11得票数 2
我正在编写代码以接收FastAPI中的JSON有效负载。
这是我的代码：
from fastapi import FastAPI, status, Request
from fastapi.responses import ORJSONResponse
import uvicorn
import asyncio
import orjson
app = FastAPI()
@app.post("/", status_code = status.HTTP_200_OK)
async def get_data(request: Request):
param = awai
浏览 15提问于2022-10-23得票数 1
回答已采纳
客户代码：
!<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title></title>
<script src="https://cdn.jsdelivr.net/npm/axios/dist/axios.min.js"></script>
</head>
<form id="uploadForm" role="form" met
浏览 20提问于2022-04-27得票数 2
回答已采纳
我正在使用FastAPI上传一个csv文件，对其执行一些修改，然后将其返回到HTML。我在前端使用Jinja2作为模板引擎和HTML。
我如何使用Jinja2模板上传csv文件，修改它，然后将它返回给客户端？
Python代码
from fastapi.templating import Jinja2Templates
from fastapi import FastAPI, File, UploadFile, Request
from io import BytesIO
import pandas as pd
import uvicorn
app = FastAPI()
templates
浏览 25提问于2022-11-25得票数 1
回答已采纳
我为自己编写的fastAPI导入的API库将许多logging.INFO级别的消息写入控制台，我希望将这些消息重定向到基于文件的日志，或者理想情况下，同时重定向到控制台和文件。以下是在我的控制台中记录事件的fastAPI模块的示例： ? 所以我尝试实现了Python answer (“使用this 3.3或更高版本很容易”)，但是它创建的日志文件("api_screen.log")总是空的…… # -------------------------- logging ----------------------------
logging_file = "ap
浏览 18提问于2020-10-13得票数 0
回答已采纳
1回答
我有一个TensorFlow 模型，其形式是h5文件。
如何上传图像并在NumPy中返回FastAPI数组？
import numpy as np
import cv2
from fastapi import FastAPI, File, UploadFile
import numpy as np
from tensorflow.keras.models import load_model
import tensorflow as tf
model=load_model("complete_model.h5")
app = FastAPI()
def prepare(im
浏览 16提问于2022-02-13得票数 1
回答已采纳
1回答
当我试图运行我的FastApi api时，我会得到这个错误。
应用= cls(app=app，**选项) TypeError：“模块”对象不可调用
我试图在其他从main.py中分离出来的文件夹上添加一个中间件，但不知道为什么不能工作。否则，当我将中间件代码添加到main.py中时，没有问题。这是我的密码，谢谢你的帮助，原谅我的英语。
main.py
from fastapi import FastAPI
from fastapi import Depends, FastAPI, HTTPException
from fastapi import Request
from routers i
浏览 2提问于2020-07-13得票数 4
回答已采纳
我正在开发一个FastAPI应用程序。它运行在码头容器中的Uvicorn上，使用的是码头组合。
我想包括一些文件，而不是*.py，以触发在开发过程中的自动重新加载。
Uvicorn需要安装可选的依赖项WatchFiles才能使用--reload-include标志，这将使我能够包括其他文件类型以触发重新加载。但是，当安装WatchFiles时(通过在启动时打印此信息来确认Uvicorn：Started reloader process [1] using WatchFiles)，根本不会自动重新加载。提醒您，这与运行命令的更改无关，无论是否包含标志。
如果没有安装WatchFiles，Uvi
浏览 6提问于2022-10-05得票数 1
我使用以下接受多个文件的FastAPI端点：
from fastapi import Request, FastAPI, File, UploadFile
from typing import List
import uvicorn
app = FastAPI()
@app.post("/multiplefiles")
async def _file_upload(keywords, files: List[UploadFile] = File(...)): #create_file
return {"len_files": keywords}
我想
浏览 4提问于2022-10-07得票数 1
回答已采纳
2回答
在此之前，我使用了Flask和Gunicorn来开发和部署红帽OpenShift中的API。多个来源声称FastAPI更快，所以我想我会在FastAPI和FastAPI中制作两个简单的API来比较它们。
用烧瓶编写的代码是：
from flask import Flask, request, json, Response, send_file
app = Flask(__name__)
def find_sums_single():
def cpu_bound(number):
return sum(i * i for i in range(number))
浏览 16提问于2022-06-29得票数 -1
回答已采纳
我使用通过FastAPI静态地提供文件夹服务
from fastapi import FastAPI
from fastapi.staticfiles import StaticFiles
app = FastAPI()
app.mount("/static", StaticFiles(directory="static"), name="static")
如何将基本身份验证(用户、密码)添加到此路由/static
浏览 18提问于2021-03-11得票数 0
回答已采纳
5回答
为什么我日志记录时FastAPI不创建日志文件
下面是我使用的代码
from fastapi.logger import logger as fastapi_logger
from logging.handlers import RotatingFileHandler
import logging
formatter = logging.Formatter(
"[%(asctime)s.%(msecs)03d] %(levelname)s [%(thread)d] - %(message)s", "%Y-%m-%d %H:%M:%S")
han
浏览 7提问于2020-03-17得票数 7
1回答
我有一个快速的api应用程序，我想有一个post请求。
from pydantic import BaseModel
from fastapi import FastAPI
class Data(BaseModel):
num: str
app = FastAPI()
@app.post("/set/")
def set_param(data: Data):
return data
当我从另一个文件发送请求时：
import requests,json
req = requests.post('http://0.0.0.0:5000/set/&
浏览 2提问于2021-01-07得票数 0
回答已采纳
1回答
我正试着用FastAPI归还一本字典。我搜索了他们的网站，却找不到任何有用的东西。也许我说的是完全错误的，但我可以想象我可以给它一个结果字典，它会返回它们作为结构在字典中？最终的目标是将这些信息从数据库中提取出来，但是为了简单和测试，我已经把它缩小到了这个范围。
from typing import List, Optional
from fastapi import FastAPI
from pydantic import BaseModel
app = FastAPI()
class Item(BaseModel):
name: str
desc
浏览 16提问于2021-08-29得票数 0
api = fastapi.FastAPI()
@api.get('/api/sum')
def caculate(z):
if z == 0 :
return fastapi.Response(content = {'Error' : 'Z must be an integer'},
status_code=400,
media_type="application/json")
return
uvicorn.run(api, host="127.0
浏览 13提问于2021-02-06得票数 0
回答已采纳
2回答
我正在试着将一个文件上传到FastApi，但是我一直收到422个验证错误。文件上载在OpenApi接口中工作，但下面的测试不起作用。
路由器：
@router.post("/files")
def file_contents(files: List[UploadFile]):
return someprocessing(files)
测试(使用来自TestClient的FastApi)：
response = client.post(
url="/files",
files={"files": ("file.xls
浏览 26提问于2022-09-05得票数 0
回答已采纳
在我的项目文件夹中，我有一个基本的index.html文件加上静态文件(js，css)以及我的main.py。
from fastapi.staticfiles import StaticFiles
from fastapi.templating import Jinja2Templates
from fastapi import Request
app = FastAPI()
templates = Jinja2Templates(directory="/")
app.mount("/", StaticFiles(directory="/"
浏览 7提问于2021-01-27得票数 18
回答已采纳
我在FastAPI上用文件名api.py编写了一个API。
from fastapi import FastAPI
from pydantic import BaseModel
app = FastAPI()
class Username(BaseModel):
Username:str
@app.post('/Username')
def Username(Username : Username):
username=Username
import metrics
metrics
浏览 1提问于2021-11-27得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
