【发布时间】:2021-03-31 08:51:30
【问题描述】:
Influxdb X 包含传感器数据并每天更新。 我正在从 influxdb X 读取原始数据(基于传感器 ID),对其进行更正,然后将更新的数据存储在 influxdb Y 中——所有这些都使用 python。每次上传到 influxdb X 的新数据都应该重复这些过程。有没有办法让任何新数据进入 influxdb X 时自动执行操作?
【问题讨论】:
Influxdb X 包含传感器数据并每天更新。 我正在从 influxdb X 读取原始数据(基于传感器 ID),对其进行更正,然后将更新的数据存储在 influxdb Y 中——所有这些都使用 python。每次上传到 influxdb X 的新数据都应该重复这些过程。有没有办法让任何新数据进入 influxdb X 时自动执行操作?
【问题讨论】:
如果不了解您的更正过程的外观以及那里的 InfluxDB 版本,很难正确地说出该怎么做。但总的来说,这看起来像是某种手动数据复制,可以使用 InfluxDB Relay https://github.com/influxdata/influxdb-relay (for v1) 等工具完成
至于更正 - 根据它的工作方式,它也可以是一个 Telegraf,使用 InfluxDB 侦听器作为输入 https://github.com/influxdata/telegraf/tree/master/plugins/inputs/influxdb_listener、一些处理器插件 https://github.com/influxdata/telegraf#processor-plugins(也可以是您自己的 Telegraf 插件)和 InfluxDB 输出。
如果您使用的是第 2 版,则有一个任务概念,可以安排任务,并且似乎是您想要的 https://docs.influxdata.com/influxdb/v2.0/process-data/
【讨论】: