curl_cffi中content_callback回调处理，并流式响应前端

第一步安装库

fastapi
curl_cffi
uvicorn
sse_starlette

代码示例

from sse_starlette.sse import EventSourceResponse
import uvicorn
from curl_cffi import requests
from fastapi import FastAPI
import queue
import threading

class ResponseCallbackHandler:
    queue = queue.Queue(maxsize=1000)
    flat = True
    
    async def yield_data(self):
        while self.flat:
            data = self.queue.get()
            if str(data) == "End":
                break
            else:
                yield data

    def put(self, e: bytes):
        self.queue.put(e)

    def end(self):
        self.flat = False
        self.queue.put(b"End")
requst


def  request_send(callback)：
	def stream_callback(data):
            callback.put(data)
  requests.request("get", "htpp://www.test.com", impersonate="chrome110",content_callback=stream_callback)
  callback.end()
	
from fastapi import FastAPI
from sse_starlette.sse import EventSourceResponse

app = FastAPI()

@app.get('/')
async def root():
	callback= ResponseCallbackHandler()
  threading.Thread(target=request_send, args=(callback)).start()
  return EventSourceResponse(callback.yield_data())

if __name__ == '__main__':
    import uvicorn
    uvicorn.run(app)

代码解释