我正在努力学习NIFI,所以这对我来说是全新的,我曾经和Talend一起工作,我很难翻译到NIFI。因此,主要思想是:例如,我在Postgresql中有两个表
餐桌城市:
ID (自动生成),city_name
餐桌人:
ID (自动生成)、first_name、last_name、city_id
我有一个CSV文件:
first_name,last_name,city_name
请解释一下,我如何从一个流程文件中插入两个表,并在表中引用城市的ID,而不是表市的名称。
谢谢
发布于 2022-05-24 11:02:32
您可以使用LookupRecord来丰富每个记录的城市id和分割两个文件的输入:匹配/不匹配。
对于匹配,您必须执行简单的插入到PERSON表-因为找到了城市id。
对于不匹配的情况,您必须生成插入/插入到城市表,然后再将所有这些记录路由到查找记录。
或者,您可以将所有内容都插入到具有与CSV匹配的结构的临时表中。
然后执行两个简单的sql语句:
https://stackoverflow.com/questions/72360592
复制相似问题