postgresql - 如何在 Apache NiFi 中不指定物理 csv 文件的情况下批量插入 PostgreSQL

Question

我需要在 Apache NiFi 中的 PostgreSQL 表中进行 BULK INSERT 而不在 COPY 命令中指定物理 csv 文件。我只是无法将 CSV 文件存储在磁盘上，并且想使用来自先前处理器并且已经是 CSV 格式的流文件进行 BULK INSERT（或者我可以将其更改为 json，这不是问题）。

请告知，在 Apache NiFi 中执行此操作的最佳方法是什么？

标签： postgresqlcsvapache-nifibulkinsert

Answer 1

PostgreSQL 的COPY操作需要一个文件的路径。我建议查看 PutDatabaseRecord，它会根据您的 CSV 数据生成 PreparedStatement 并在单个批次中执行该语句（除非Maximum Batch Size已设置）