希望你们都过得很好。
我正在乞求我的Nifi学习,我想复制一个我在其他平台上运行的过程。
我的目标是读取CSV并逐行处理,以插入到sql服务器表中。
到目前为止,我可以通过以下方式做到这一点:
GetFile -> SplitRecord -> ConvertRecord (to json) -> ConvertJSONtoSQL -> UpdateAttribute (date conversion) -> PutSQL。
但是如果记录已经存在于destiny表中,则需要进行验证。有人能帮我吗?我已经找过了,但我找不到。
如果你们有一个更好的、完全不同的解决方案,没问题,我对任何改变都持开放态度。
提前感谢!
发布于 2020-12-22 03:24:35
GetFile -> SplitRecord -> EvaluareJSONPath (将唯一键放入属性) -> GenerateTableFetch + ExecuteSQL (使用上一步中的唯一/主键从数据库中获取相应记录) -> RouteOnAttribute (检查上一步中的记录是否存在-如果没有记录,则根据您的要求继续插入其他更新/忽略) -> transform (使用ConvertJSONtoSQL -> UpdateAttribute (日期转换)) -> PutSQL。
应该是这样的
https://stackoverflow.com/questions/65393891
复制相似问题