我在NiFi中有数据管道,它通过"ExtractText“处理器监听系统日志和处理接收到的数据并提取属性,然后通过"ReplaceText”进行内流输入格式,最后由"PutInflux“处理器插入到进水数据库。但是我在putInflux处理器前有一个很长的队列,因为插入速度比生成的数据慢。请帮助我提高插入速度。数据PipeLine
发布于 2018-11-13 08:45:06
谢谢Mattyb,我增加了PutInfluxDB处理器中的线程数量,并解决了这个问题:)
发布于 2018-11-12 16:04:28
您是一次将多行放入内流(即流文件中的多行)还是一次放入一行?如果后者,尝试MergeContent或MergeRecord之前的PutInfluxDB,以获得多行文件。这样你就不用支付通过电线传输每条线路的开销了,你可以一次把很多线路都放进去。
https://stackoverflow.com/questions/53265247
复制相似问题