jackson jsonlines 处理-读取以及生成

jsonlines 在数据分析处理以及批量json 处理中是比较常用的,以下是基于jackson 的处理

场景说明

基于jackson 读取以及生成jsonlines

参考代码

jsonlines 格式

{"0":"ddd","1":"11","2":"111","3":"111"}
{"0":"ddd","1":"12","2":"112","3":"112"}
{"0":"ddd","1":"13","2":"113","3":"113"}
....
  • 读取
public  static void readJsonLines() throws IOException {
    InputStream stream = Application.class.getClassLoader().getResourceAsStream("demoapp22.ldjson");
    JsonMapper reader=  JsonMapper.builder().build();
    MappingIterator<JsonNode> items = reader.readerFor(JsonNode.class).readValues(stream);
    while (items.hasNextValue()){
        System.out.println(items.nextValue());
    }
}
  • 生成
public static void writeExcelContent2JSONLines2(List<Object> input) throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
    try (OutputStream fileOutputStream = new FileOutputStream("demoapp22.ldjson")) {
        try (SequenceWriter seq = objectMapper.writer()
              // withRootValueSeparator 此处是核心,需要符合jsonlines的格式,数据就是一个pojo
                .withRootValueSeparator("\n").writeValues(fileOutputStream)) {
            input.forEach(new Consumer<Object>() {
                @SneakyThrows
                @Override
                public void accept(Object s) {
                    seq.write(s);
                }
            });
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

说明

以上基于jackson 进行jsonlines 的读取以及写入操作,对于需要集成jsonlines 的可以参考

参考资料

https://jsonlines.org/

jackson jsonlines 处理-读取以及生成

上一篇:grpc的.net core使用


下一篇:Linux之开机、重启和用户登录注销