如何将 AVRO 模式转换为线路协议以便使用 Apache Ni-Fi 将数据插入 InfluxDB

How to convert an AVRO scheme into line protocol in order to insert data into InfluxBD with Apache Ni-Fi

我正在使用 Apache Ni-Fi 创建数据管道,以将数据从远程 MySQL 数据库复制到 InfluxDB。

我使用 QueryDatabaseTable 处理器从 MySQL 数据库中提取数据,然后我使用 UpdateRecord 进行一些数据转换,我想使用 PutInfluxDB 将时间序列插入我在 Linux.

QueryDatabaseTable处理器的数据使用AVRO方案,我需要通过配置哪些是标签,哪些是测量值,将其转换成线路协议。

但是,我没有找到任何允许进行这种转换的处理器。

有什么提示吗?

谢谢,

贝尔纳多

没有用于 InfluxDB 线路协议转换的内置处理器 - 如果您想自己做,您可以编写一个 ScriptedRecordWriter,但是有一个项目已经为 NiFi reader 实现了线路协议 here 由 InfluxData 提供,似乎是活跃的并且是最新的。

查看文档将其添加到 NiFi here