主页 / 问题 / 1590532
Accepted
Kvibla
Asked:2024-08-14 00:37:36 +0000 UTC2024-08-14 00:37:36 +0000 UTC

如何处理带有多个事件的 HTTP 响应？

  • 772

我向该网站发出了后期请求并收到了很多回复。问题是它不是经典的 json 格式，而是这样的：

event:conversation.chat.created
data:{"id":"xxxxxxxx","conversation_id":"xxxxxx","bot_id":"Xxxxxxx","created_at":xxxxxxx,"last_error":{"code":0,"msg":""},"status":"created","usage":{"token_count":0,"output_count":0,"input_count":0}}

event:conversation.chat.in_progress
data:{"id":"xxxxxxxxx","conversation_id":"xxxxxxxxxxx","bot_id":"xxxxxxxxxxx","created_at":xxxxxxxx,"last_error":{"code":0,"msg":""},"status":"in_progress","usage":{"token_count":0,"output_count":0,"input_count":0}}
#Заменил значения на 'XXXX'

服务器响应超过 9-10 个，并且全部在一个响应中收到。 Postman 通常会划分它们，而 Python 不会：

在此输入图像描述

当我尝试将所有这些转换为 json via 时responce.json()，它开始给出错误json.decoder.JSONDecodeError: Expecting value: line 1 column 1 (char 0)

尝试翻译成文本导致我无法添加逗号、删除不必要的\n等等。我应该怎么办？

python

1 个回答

  1. Best Answer

    问题中显示的格式看起来很像Server-Sent Events。

    如果服务器响应正确，您可以使用现成的库（例如requests-sse）Content-Type来解析它。

    那里的文档很少，但一般来说并不是特别需要 - 它是库的一个相当简单的包装requests。主要是要记住三件事：

    • 命名参数**kwargs直接传递给requests.request()，这允许您填充您喜欢的任何请求参数（或者您甚至可以在参数中传递整个Sessionsession）；
    • 事件内容是一个字符串；如果你想将其作为 JSON 进行处理，那么不要忘记将其放入event.data某种json.loads;中。
    • 当连接丢失时，库会自动重新连接（我没有看到禁用此功能的标准方法，尽管您可以尝试在中抛出异常on_error）；在编写代码时值得记住这一点。
    #!/usr/bin/env python3

from requests_sse import EventSource

with EventSource(
    "https://sse-demo.netlify.app/sse",
    timeout=60,
    method="POST",
    # Параметры, явно не объявленные в EventSource, попадут в **kwargs
    headers={"User-Agent": "i-am-not-a-python-script/999.99"},
    json={"hello": "world"},
) as event_source:
    try:
        for event in event_source:
            print("Событие:", event.type)
            print("Данные (в виде строки):", event.data)
    except Exception as exc:
        print("Кажется, что-то пошло не так")
        raise exc
    • 0

相关问题