使用 Akka Stream 传输巨大的 json

我有一个 json 板的巨大 http 响应问题，其中只有部分是感兴趣的。 我无法更改响应结构。 这是一个例子

{
  "searchString": "search",
  "redirectUrl": "",
  "0": {
    "numRecords": 123,
    "refinementViewModelCollector": {},
//    Lots of data here
    "results": [
      {
        "productCode": "123",
        "productShortDescription": "Desc",
        "brand": "Brand",
        "productReview": {
          "reviewScore": 0
        },
        "priceView": {
          "salePriceDisplayable": false,
        },
        "productImageUrl": "url",
        "alternateImageUrls": [
          "url1"
        ],
        "largeProductImageUrl": "url4",
        "videoUrl": ""
      },
      {
        "productCode": "124",
        "productShortDescription": "Desc",
        "brand": "Brand",
        "productReview": {
          "reviewScore": 0
         },
        "priceView": {
          "salePriceDisplayable": false,
        },
        "preOrder": false,
        "productImageUrl": "url",
        "alternateImageUrls": [
          "url1"
        ],
        "largeProductImageUrl": "url4",
        "videoUrl": ""
      }
    ]
    //lots of data here
  }
}

我的兴趣点是条目resultsJason Array，但它们位于 json 的中间

我创建了一个小型 Play WS 客户端，如下所示：

val wsClient: WSClient = ???
val ret = wsClient.url("url").stream()
ret.flatMap { response =>
  response.body.via(JsonFraming.objectScanner(1024))
    .map(_.utf8String)
    .runWith(Sink.foreach(println))
}

这是行不通的，因为它会将整个 json 板作为 Json 对象。我需要跳过一些数据直到"results":条目出现在流中，然后开始解析条目并跳过所有其余的。 有什么想法如何做到这一点？

查看Alpakka 的 JSON 模块 https://doc.akka.io/docs/alpakka/current/data-transformations/json.html#streaming-of-nested-structures，它可以流式传输嵌套 JSON 结构的特定部分：

response
  .body
  .via(JsonReader.select("$.0.results[*]"))
  .map(_.utf8String)
  .runWith(Sink.foreach(println)) // or runForeach(println)