是否存在一些良好的开源连接器，可以实现从InfluxDB到Flink的数据传输

Question

当我们尝试构建自己的时态数据库系统时，我的团队遇到了一些问题。从头开始，我们尝试了解influx DB和Flink之间的数据传输过程。我们的基本思想是：Flink从influxDB中读取数据，Flink使用这些数据基于Flink的ML库进行一些建模。 （如图中的红色圆圈所示）。但是，我们仅找到一些开放源代码存储库，这些存储库提供了一个接收器，可以从Flink（例如Flink InfluxDB Connector）向InfluxDB发送数据。因此，如果您知道一些像我描述的例子，请告诉我。非常感谢。

<< img src =“ https://image.soinside.com/eyJ1cmwiOiAiaHR0cHM6Ly9pLnN0YWNrLmltZ3VyLmNvbS9zU0gwMS5qcGcifQ==” alt =“在此处输入图像描述”>

Answer 1

您可以轻松构建自己的接收器。实施扩展RichSinkFunction的接收器并使用influxdb library

您可以看到RichSinkFunction here的示例

Answer 2

我不相信有人为InfluxDB实现了Flink源连接器。但是InfluxDB的概念是subscriptions，可能会有所帮助。