Nifi 1.8 csv 数据库摄取

Question

在 nifi 1.8 中是否有办法让 PutDatabaseRecord 通知您在 CSV 文件的哪一行出现错误或架构不对应？

我有兴趣将大型 CSV 文件转储到数据库中，但我也想记录错误文件和发生错误的行。 我不想为了记录它而丢弃整个文件。 我可能会忽略坏行并继续插入好行，但我也希望能够记录坏行和文件名。

如果可能的话，我还想发送一个信号，可能会采取

Answer 1

您可以使用 ValidateRecord 并仅将“有效”关系发送到 PutDatabaseRecord，然后将“无效”关系路由到 PutFile 等其他地方，以便查看无效记录。