FastAPIでレスポンスが返ってこない

Question

FastAPIとReactでアプリを開発しています。テスト用のAPI(routers.py)を作成して、リクエストの内容をログに残すミドルウェア(check2.py)を用意しました。
しかし、/new_postに適切にリクエストをしてもレスポンスが帰ってきません。
しかしミドルウェア(check2.py)の処理の中身をコメントアウトし
response = await call_next(request)
return response
2行だけにしてAPIにリクエストを飛ばしたところ正常に応答が帰ってくるようになりました。
このことからログを表示するために作成したミドルウェアに問題があると考えられますがどこが原因か分からないため教えていただけないでしょうか。

from fastapi import Request
import json

async def log_request2(request: Request, call_next):
    if "application/json" in request.headers.get("Content-Type", ""):
        try:
            json_data = await request.json()
            print("Request JSON Body:")
            print(json.dumps(json_data, indent=2))
        except Exception as e:
            print("Failed to parse JSON body:", str(e))
    else:
        body = await request.body()
        print("Request Body:")
        print(body)
    response = await call_next(request)
    return response

from fastapi import FastAPI, Request
from fastapi.middleware.cors import CORSMiddleware
from database.db import database
from middlewares.check2 import log_request2
from users.router import router as userrouter
from photos.routers.routers import router as photorouter

import logging

app = FastAPI()

origins = [
    "http://localhost:3000",
]

app.add_middleware(
    CORSMiddleware,
    allow_origins=origins,
    allow_credentials=True,
    allow_methods=["*"],
    allow_headers=["*"],
)

app.middleware("http")(log_request2)

app.include_router(photorouter)

router = APIRouter()

class Post(BaseModel):
    key1: str
    key2: str

@router.post("/new_post", status_code=status.HTTP_201_CREATED)
async def new_post(post_data: Post):
    print("/new_post")
    # 受け取ったデータのkey1とkey2の値を変更する
    response_data = {"key1": "変換済み1 " + post_data.key1, "key2": "変換済み2 " + post_data.key2}
    # 変更後のデータをJSONレスポンスとして返す
    return response_data

Comments

[hoshi-takanori]

これかな？
https://github.com/tiangolo/fastapi/issues/394

追記。また、どんなアプリを開発するかによりますが、ユーザー登録やログインにおいてパスワードなどの秘密情報をログに残すことは慎むべきでしょうね。
https://www.jpcert.or.jp/java-rules/fio13-j.html

Answer 1

GitHubの記事を教えていただきありがとうございます。まさしく直面している問題について書かれていました。
読んでも完璧には理解できなかったのですが、ミドルウェアでRequestのbodyを消費してしまうのが問題ということで、ミドルウェアを使わずにrouterに依存関係を追加する方法でロギングするようにしたところ正常に動作するようになりました。
ありがとうございました。

async def log_json(request: Request):
    if "application/json" in request.headers.get("Content-Type", ""):
        try:
            json_data = await request.json()
            print("Request JSON Body:")
            print(json.dumps(json_data, indent=2))
        except Exception as e:
            print("Failed to parse JSON body:", str(e))
    else:
        # リクエストボディを非同期に取得
        body = await request.body()
        print("Request Body:")
        print(body)

@router.post("/new_post", status_code=status.HTTP_201_CREATED)
async def new_post(post_data: Post, log_data: str = Depends(log_json)):
    print("/new_post")
    # 受け取ったデータのkey1とkey2の値を変更する
    response_data = {"key1": "変換済み1 " + post_data.key1, "key2": "変換済み2 " + post_data.key2}
    # 変更後のデータをJSONレスポンスとして返す
    return response_data