Spring Boot 集成到 Apache NIFI

Question

我正在尝试在 Nifi 中创建一个看起来像这样的进程 => 读取 csv，转换为 json 并将其写入 db，但我必须使用我的 spring boot 项目中的 dao 类而不是 PutDatabaseRecord。

我尝试过使用SpringContextProcessor（制作了将spring boot项目作为依赖项的spring项目），但Nifi似乎没有赶上配置yml文件并且无法创建与db的连接。

有什么办法可以解决这个问题吗？

Answer 1

已经有可以在 CSV 和 JSON 之间转换的处理器，例如 ConvertRecord。所以我建议编写一个需要 JSON 并使用你的 spring-boot DAO 类的自定义处理器。