希望你们都做得很好。
我开始学习Nifi,我想复制我在其他平台上运行的过程。
我的目标是读取CSV并逐行处理它,以便插入到sql server表中。
到目前为止还不错,我能够用以下方法做到这一点:
GetFile->SplitRecord->ConvertRecord(到json(->将JSON转换为SQL->UpdateAttribute(日期转换(->PutSQL。
但如果记录已经存在于命运表中,我需要验证。有人能帮我吗?已经在找了,但我没能找到类似的东西。
如果你们有一个更好的、完全不同的解决方案,没问题,我愿意接受任何改变。
提前感谢!
GetFile
->SplitRecord
->EvaluareJSONPath
(将唯一密钥放入属性(->GenerateTableFetch + ExecuteSQL
(使用来自上一步骤的Unique/Primary关键字从DB获得相应的记录(->RouteOnAttribute
(检查以前的记录是否存在-如果没有,则根据您的要求继续插入其他更新/忽略(->变换(具有ConvertJSONtoSQL
->UpdateAttribute
(日期转换((->PutSQL
。
应该是像这个