如何处理 Python 中的传输编码？

问题描述

我正在为小型机器学习项目开发分析 API。我创建了一个端点，它使用 Flask 的 stream_with_context 函数，如下例所示：

def post():
       # some logic
       [...]

        try:
            res = get_data_from_elastic()

            def generate():
                for hit in res:
                    resp_dict = {
                        "timestamp": hit.timestamp,"user_id": hit.user_id,"node_id": hit.node_id,"loc": hit.loc,"is_target": hit.is_target
                    }
                    yield json.dumps(resp_dict) + '\n'

            return Response(stream_with_context(generate()),status=200,mimetype="application/json")

        # except:
           # some exception handling

它不是从我的代码中精确提取的，但生成器的工作原理相同。我使用 Python 请求连接 API，代码如下：

response = requests.post(analytic_api_url,headers={'Authorization': token},data={'since': since,'till': till})

当我连接到 API 并一次下载少量数据时，一切正常。不幸的是，当我尝试一次下载更多数据时，出现以下错误：

ChunkedEncodingError: ("Connection broken: InvalidChunkLength(got length b'',0 bytes read)",InvalidChunkLength(got length b'',0 bytes read))

由于错误是关于 chunked encoding，我检查了诸如在服务器响应中设置 transfer-encoding: chunked 标头之类的内容，我还尝试使用 stream=True 中的 requests 参数库 - 这些解决方案都不起作用。 我应该如何处理这个问题？我应该明确设置其他一些 transfer-encoding 标头，还是为我的 API 创建另一个生成器？

感谢您的帮助！

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）