请告诉我如何使用nifi将多个json数据插入hbase
puthbasejson图像输出
当我们尝试插入多个id或对象时,puthbasecell图像输出。这是我用puthbasecell试过的文件
{"id" : "1334134","name" : "Apparel Fabric","path" : "Arts, Crafts & Sewing/Fabric/Apparel Fabric"},
{"id" : "412","name" : "Apparel Fabric","path" : "Arts, Crafts & Sewing/Fabric/Apparel Fabric"}
puthbasecell处理器的图像
1条答案
按热度按时间8wtpewkr1#
puthbasejson期望每个流文件包含一个json文档,该文档在hbase中成为一行。行id可以在处理器中使用表达式语言指定,也可以来自json中的一个字段。json中的其他字段/值对成为hbase中行的列/值。
如果您想使用puthbasejson,您只需要在nifi中分割数据,然后数据就可以到达这个处理器。有很多方法可以做到这一点。。splitjson,splittext,splitcontent,executescript,自定义处理器。
另外,还有一个puthbaserecord处理器,它可以使用记录读取器从流文件中读取记录并将它们全部发送到hbase。在您的情况下,您需要一个json记录读取器。数据还必须是记录阅读器能够理解的格式,我相信对于json,它需要是一个文档数组。