如何在FastAPI中的HTTP请求之间共享变量？

Question

如何在 FastAPI 中的 HTTP 请求之间共享变量值？例如，我有一个 POST 请求，在该请求中我获取了一些音频文件，然后将它们的信息转换为 Pandas Dataframe。我想在 GET 请求中发送该 Dataframe，但我无法访问 GET 上的 Dataframe > 请求范围。

@app.post(
    path="/upload-audios/",
    status_code=status.HTTP_200_OK
)
async def upload_audios(audios: list[UploadFile] = File(...)):
    filenames = [audio.filename for audio in audios]
    audio_data = [audio.file for audio in audios]
    new_data = []
    final_data = []
    header = ["name", "file"]
    for i in range(len(audios)):
        new_data = [filenames[i], audio_data[i]]
        final_data.append(new_data)
    new_df = pd.DataFrame(final_data, columns=header)
    return f"You have uploaded {len(audios)} audios which names are: {filenames}"

@app.get("/get-dataframe/")
async def get_dataframe():
    pass

Answer 1

如果您需要对该变量进行只读访问，并且/或您从不希望在读取它之前它会被其他请求修改（换句话说，您从不希望为多个客户端提供服务） ，以及您的应用不使用多个工作线程 ——自从每个工作线程都有自己的东西、变量和内存） - 你可以（正如 @MatsLindh 在上面的评论中提到的）在端点外部（换句话说，全局）声明一个字典，例如，foo = {}，并在端点内部为其分配一个键，例如， foo['pd'] = df（稍后您可以在另一个请求到达时检索该变量），或者将您的变量声明为 global （如此处），或者最好是将变量存储在应用实例上，这允许您使用通用 app.state 属性存储任意额外状态 - 请参阅此答案介绍如何在应用程序启动之前执行此操作。例如：

from fastapi import FastAPI

app = FastAPI()

@app.post("/create")
async def create_dataframe():
    # df = ...  # create the df here
    app.state.df = df

然后，在 get_dataframe 端点内，您可以像这样检索 df：

@app.get("/get")
async def get_dataframe():
    df = app.state.df

或者，如果 app 实例在您正在工作的文件（假设您在子模块中定义了端点，与主模块分开，如所述此处），您可以从 Request 对象获取 app 实例：

from fastapi import Request

@app.get('/get')
async def get_dataframe(request: Request):
    df = request.app.state.df

否则，如果您需要该变量/对象为 <在不同客户端以及多个进程/工作进程之间共享，可能还需要对其进行读/写访问，您应该使用数据库存储，例如 PostgreSQL， SQLite、MongoDB、等，或者Key-Value存储（缓存），例如Redis< /a>、Memcached 等。您可能想看看这个答案也是如此。