问题[apache-nifi](coding)

传入的 csv 文件具有以下模式：

 latitude;longtitude
 90.232;24.244

我需要通过使用新字段“json”更新传入模式来生成流文件。

预期输出模式为：

latitude;longtitude;json
90.232;24.244;"{\"type\":\"Point\",\"coordinates\":[90.232,24.244]}"

所以我需要提取纬度和经度值并将它们放入 json（表示为字符串值）。

为了这个目的我使用了带有属性的 UpdateRecord：

/json 值为：

  {"type":"Point","coordinates":[${\latitude},${\longtitude}]}

我也尝试过：

 {"type":"Point","coordinates":[${latitude},${longtitude}]}

但输出是：

 latitude;longtitude;json
 90.232;24.244;"{\"type\":\"Point\",\"coordinates\":[,]}"

因此没有任何东西被放置在坐标“占位符”中。

有人能帮助我吗？

我在尝试从 Apache NiFi 中的 joltTransform 处理器构造输出 JSON 时遇到问题。我需要从 idByLine 数组中提取值并将它们与 orderLine 数组中的值进行匹配。这是我的输入 JSON 的简化版本：

  "orderLine": [
      "ID": "1"
    },
      "ID": "2"
    }
  ],
  "idByLine": [
    {
      "idLine": "1",
      "orderId": "AMD123"
    },
    {
      "idLine": "2",
      "orderId": "AMD555"
    }
  ]
}

我的目标是创建以下输出对象：

[ {
  "idLine" :  "AMD123" 
}, {
  "idLine" : "AMD555"
} ]

我正在努力设计正确的 JOLT 规范来实现这一目标。有人可以帮助我制定适当的 JOLT 规范来生成所需的输出吗？