如何从 Rust 中的文件/流中懒惰地读取多个 JSON 值？

Question

我想从 Rust 中的文件/阅读器中读取多个 JSON 对象，一次一个。不幸的是serde_json::from_reader(...) 只读取到文件结束；似乎没有任何方法可以使用它来读取单个对象或懒惰地迭代对象。

有没有办法做到这一点？使用 serde_json 是理想的，但如果有不同的库，我愿意使用它。

目前我将每个对象放在单独的行上并单独解析它们，但我真的不想这样做。

使用示例

main.rs

use serde_json;

fn main() -> Result<(), Box<dyn std::error::Error>> {
   let stdin = std::io::stdin();
   let stdin = stdin.lock();

   for item in serde_json::iter_from_reader(stdin) {
     println!("Got {:?}", item);
   }

   Ok(())
}

in.txt

{"foo": ["bar", "baz"]} 1 2 [] 4 5 6

示例会话

Got Object({"foo": Array([String("bar"), String("baz")])})
Got Number(1)
Got Number(2)
Got Array([])
Got Number(4)
Got Number(5)
Got Number(6)

Answer 1

I wanted to do it in Python 时这很痛苦，但幸运的是，在 Rust 中，这是事实标准 serde_json crate 的直接支持功能！它没有作为单个便利函数公开，但我们只需要创建 a serde_json::Deserializer 从我们的文件/阅读器读取，然后使用其 .into_iter() 方法获取 a StreamDeserializer iterator 产生包含 Results 的 serde_json::Value JSON 值.

use serde_json; // 1.0.39

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let stdin = std::io::stdin();
    let stdin = stdin.lock();

    let deserializer = serde_json::Deserializer::from_reader(stdin);
    let iterator = deserializer.into_iter::<serde_json::Value>();
    for item in iterator {
        println!("Got {:?}", item?);
    }

    Ok(())
}

需要注意的一点：如果遇到语法错误，迭代器将开始产生无限序列的错误结果，并且永远不会继续前进。您需要确保处理循环内部的错误，否则循环将永远不会结束。在上面的 sn-p 中，我们通过使用? 问号运算符来打破循环并从我们的函数返回第一个serde_json::Result::Err。