如何将流数据保存到InfluxDB？

Question

我正在尝试以流式方式（以最少的延迟）将数据保存到我的InfluxDB数据库中。目前，我已批量保存它。

当前设置-基于间隔

当前，我有一个Airflow实例，我每5分钟从REST API中读取一次数据，然后将其保存到InfluxDB。>>

所需设置-连续

而不是每5分钟保存一次数据，我想通过Web套接字建立一个连接（我想），并在数据到达时进行保存。我以前从未做过此事，而使我感到困惑的是它是如何实际完成的？我有一些问题：

• 我为它编写了代码，是否像守护程序一样保持它的代码？
• 我是否需要使用Telegraf这样的工具，或者不是这种情况（example article）
• 代替气流（因为它用于批处理），我需要使用类似Apache Beam或Spark的东西吗？

如您所见，从这一切开始，我从什么地方开始阅读，阅读什么以及如何变得有意义。任何关于设置方向和/或指导的建议将不胜感激。

我正在尝试以流式方式（以最少的延迟）将数据保存到我的InfluxDB数据库中。目前，我已批量保存它。当前设置-基于间隔的...

Answer 1

如果我的理解正确，您很想编写一个Java服务来处理传入的数据，因此解决方案之一是使用例如jetty来实现一个websocket。