fastapi：客户端的要求保持待处理

Question

我创建了一个简单的Fullstack应用程序，需要根据特定请求在背面进行一些长时间的计算。为了遵循这些计算的进度，我将以特定的时间间隔向后端发送投票请求。

问题在于那些投票请求一直待定，直到我手动重新加载后端为止。

#Server side
Initial request

@app.post("/", status_code=202)
async def read_root(
  background_tasks: BackgroundTasks,
  file: Optional[UploadFile] = File(None), 
):
  task_id = str(uuid.uuid4())
  background_tasks.add_task(launch_process, task_id,file)
  #launch_process does the calculations and keeps track of the progress
task_id = str(uuid.uuid4())
 return {"id": task_id }

我正在将nextJ用于前端，但是出于演示目的，我使用的是香草JS，因为它也不起作用。

const progressDiv = document.getElementById('progressDiv')

const sendFile = async (data) => {

 let progress = 0
 progressDiv.textContent = progress
 
 const res1 = await fetch("http:localhost:8000", {
    method: 'post',
    body: data,
 })
 
 const jsonData = await res1.json()
 const id = jsonData.id

 let finish = false
 while(!finish){
  
   const idInterval = setInterval(()=>{
  
      fetch(`http://localhost:8000/polling/${id}`)
           .then(res => res.json())
           .then(json => {
             progress = json.progress 

             progressDiv.textContent = progress

             if(progress === 100){
               finish = true
               clearInterval(idInterval)
             }

           })
   }, 3000)
 }
}

所有的投票请求都不会通过并保持待处理

@app.get("/polling/{task_id}")
def polling(task_id: str):

  progress = store[task_id]["progress"]
  # the store keeps tracks of all the data 

  return {"progress": progress}

Answer 1

感谢 @chris 建议，我了解我的问题的来源。

我的背景任务函数（auginn_process（））具有一些重型同步计算。这些计算阻止了主线程。
因此，尽管我最初的帖子请求给出了响应，但我正在进行的abound_process（）呼叫都阻止了所有正在进行的请求（待定）。

我解决的方式是使用

我将代码从以下方法更改

async def launch_process(task_id, file):
    content = await file.read()
    long_synchronous_function(content, task_id)
    return

为：

from fastapi.concurrency import run_in_threadpool

async def launch_process(task_id, file):
    content = await file.read()
    await run_in_threadpool(lambda: long_synchronous_function(content, task_id))
    return

A>也帮助了我（它为问题提供了多种解决方案）。