Apache NiFi - 将 XML 数据插入 Postgres

Question

我有一个简单的要求。我需要使用 NiFi 将 xml 数据插入到相应的 Postgres 表中。这样做的分步方法是什么？

谢谢！

Answer 1

您可以使用TransformXml处理器和XSLT 将您的 XML 转换为 JSON。如果您的 XML/JSON 是“扁平的”，这意味着您在传出的 JSON 中只有一级字段，您可以使用ConvertJSONToSQL后跟PutSQL将记录插入到您的数据库中。如果您的 JSON 不是平面的并且您想将其转换为平面对象（对于转换/放置部分），您可以使用JoltTransformJSON来做到这一点。

在 NiFi 1.2.0 中，您可以用 PutDatabaseRecord 替换 ConvertJSONToSQL -> PutSQL 部分；您可以设置 JsonPathReader 或 JsonTreeReader 来获取记录。目前还没有 XML 记录阅读器，但在 1.2.0 中有一个 ScriptedRecordReader 和一个示例 Groovy 脚本，用于读取平面 XML 文件。