import httpx
				from httpx_sse import connect_sse
				# 省略無(wú)關(guān)代碼
				try:
                    with httpx.Client() as client:
                        with connect_sse(client, "GET", url, params=param) as event_source:
                            clear_textbox(response_textbox)
                            # 把 iter_sse() 迭代完, 就相當(dāng)于處理完了一次流式調(diào)用
                            for sse in event_source.iter_sse():
                                # 流式響應(yīng)中,每次響應(yīng)體的處理邏輯
                                print(f"generated_answer的值是: '{sse.data}'")
                                response = sse.data
                                if response != '':
                                    # self.response = response
                                    append_text(response_textbox, response)

                except httpx.RequestError as e:
                    print(f"請(qǐng)求錯(cuò)誤：{e}")
                except Exception as e:
                    print(f"發(fā)生了一個(gè)錯(cuò)誤：{e}")

@contextmanager
def connect_sse(
    client: httpx.Client, method: str, url: str, **kwargs: Any
) -> Iterator[EventSource]:
    headers = kwargs.pop("headers", {})
    headers["Accept"] = "text/event-stream"
    headers["Cache-Control"] = "no-store"

    with client.stream(method, url, headers=headers, **kwargs) as response:
        yield EventSource(response)

import httpx
from httpx_sse import EventSource
from typing import Any, Iterator
from contextlib import contextmanager
import json
# 自定義調(diào)用sse接口
    @contextmanager
    def custom_connect_sse(
            self, client: httpx.Client, method: str, url: str, **kwargs: Any
    ) -> Iterator[EventSource]:
        headers = kwargs.pop("headers", {})
        # 只有當(dāng)沒(méi)有指定Accept時(shí)才添加默認(rèn)值
        headers["Accept"] = "*/*"
        headers["Cache-Control"] = "no-store"

        with client.stream(method, url, headers=headers, **kwargs) as response:
            content_type = response.headers.get('content-type', '').lower()
            json_flag = False
            if 'text/event-stream' in content_type:
                # 處理SSE流
                yield json_flag, EventSource(response)
            elif 'application/json' in content_type:
                # yield response  # 在這里你可以決定如何進(jìn)一步處理這個(gè)JSON響應(yīng)
                # 讀取并合并所有文本塊
                text_data = ''.join([chunk for chunk in response.iter_text()])
                # 解析整個(gè)響應(yīng)體為JSON
                json_data = json.loads(text_data)
                json_flag = True
                yield json_flag, json_data

# 使用自定義的connect_sse函數(shù)
                try:
                    with httpx.Client() as client:
                        with self.custom_connect_sse(client, "GET", url, params=param, headers=headers) as (json_flag, event_source):
                            if json_flag:
                                code = event_source.get("code")
                                msg = event_source.get("msg")
                                print(f"Code: [code], Message: {msg}")
                            else:
                                full_answer = ""
                                clear_textbox(response_textbox)
                                for sse in event_source.iter_sse():
                                    print(f"generated_answer的值是: '{sse.data}'")
                                    response = sse.data
                                    if response:
                                        append_text(response_textbox, response)
                                        full_answer += response
                                user_record += reply + full_answer + "\n"
                                print(f"user_record:{user_record}")

                except httpx.RequestError as e:
                    print(f"請(qǐng)求錯(cuò)誤：{e}")
                except Exception as e:
                    print(f"發(fā)生了一個(gè)錯(cuò)誤：{e}")