2

我正在尝试连接到 http API。此 API 使用 ndjson 响应，即换行符分隔的 json 字符串。在我全部下载它们之前，我需要一一使用这些行（实际上甚至在服务器知道它将在未来的行上输出什么之前）。在 Python 中，我可以通过以下方式实现：

import requests, json

lines = requests.get("some url", stream=True).iter_lines()
for line in lines:
    #parse line as JSON and do whatever

它就像魅力一样。

我希望在 Nim 中完成相同的效果，但程序会阻塞。例如，我尝试仅加载响应的第一行：

import httpclient, json, streams

var stream = newHttpClient().get("some url").bodyStream
var firstLine = ""
discard stream.readLine(firstLine )
echo firstLine

但没有运气 - 也就是说，程序永远不会回声。我也尝试过streams.lines迭代器，但这也没有帮助。

是否有一些类似于 Python 片段的习语可以让我轻松地逐行使用 http 响应流？

4

1 回答 1

1

解决方案是使用net@pietroppeter 链接的问题中的模块。这最初对我不起作用，因为我没有正确构造 HTTP 请求。结果代码：

import net, json

const HOST = "host"
const TOKEN = "token"

iterator getNdjsonStream(path: string): JsonNode =
    let s = newSocket()
    wrapSocket(newContext(), s)
    s.connect(HOST, Port(443))
    var req = &"GET {path} HTTP/1.1\r\nHost:{HOST}\r\nAuthorization: {TOKEN}\r\n\r\n"
    s.send(req)
    while true:
        var line = ""
        while line == "" or line[0] != '{':            
            line = s.recvLine
        yield line.parseJson

httpClient我认为使用该模块无法实现这一点。异步版本可能看起来可以做到，但在我看来，您只能在 Future 完成后使用接收到的数据，即在所有数据下载之后。事实上，这样一个简单的想法不能简单地完成，而且我找不到可以找到的示例，这导致了几天的挫败感，并且需要在 10 年的编程之后开设一个 stackoverflow 帐户。

于 2020-11-15T10:56:28.630 回答