Nifi CSV行处理以检查主键



希望你们都做得很好。

我开始学习Nifi,我想复制我在其他平台上运行的过程。

我的目标是读取CSV并逐行处理它,以便插入到sql server表中。

到目前为止还不错,我能够用以下方法做到这一点:

GetFile->SplitRecord->ConvertRecord(到json(->将JSON转换为SQL->UpdateAttribute(日期转换(->PutSQL。

但如果记录已经存在于命运表中,我需要验证。有人能帮我吗?已经在找了,但我没能找到类似的东西。

如果你们有一个更好的、完全不同的解决方案,没问题,我愿意接受任何改变。

提前感谢!

GetFile->SplitRecord->EvaluareJSONPath(将唯一密钥放入属性(->GenerateTableFetch + ExecuteSQL(使用来自上一步骤的Unique/Primary关键字从DB获得相应的记录(->RouteOnAttribute(检查以前的记录是否存在-如果没有,则根据您的要求继续插入其他更新/忽略(->变换(具有ConvertJSONtoSQL->UpdateAttribute(日期转换((->PutSQL

应该是像这个

相关内容

  • 没有找到相关文章

最新更新