为 influxdb 创建数据 generator/recycler
creating a data generator/recycler for influxdb
我想为实验室环境创建某种数据生成器。
我想创建某种脚本,它将获取数据库名称和逗号分隔的指标名称,并将从 influx-db 中获取旧数据,将其时间戳更改为当前时间,并将其保存回来涌入数据库。
我不确定最好和最简单的方法是什么,
python 脚本?电容器udf?
有什么想法吗?
我是 tick 环境的新手,所以我真的可以使用一些想法:)
谢谢,
大卫,
找到了完美的方式,
快速简单,使用 kapacitor,甚至不需要创建 udf...
创建此 tick 脚本并将其定义为 kapacitor 任务:
var data = batch
|query(''' SELECT * FROM "My_DB"."My_RP"."My_Measurement" ''')
.period(1d)
.every(30s)
.offset(10d)
data
|shift(10d)
|influxDBOut()
.create()
.database('My_DB')
.measurement('My_Measurement')
就像魔术一样工作!
我想为实验室环境创建某种数据生成器。
我想创建某种脚本,它将获取数据库名称和逗号分隔的指标名称,并将从 influx-db 中获取旧数据,将其时间戳更改为当前时间,并将其保存回来涌入数据库。
我不确定最好和最简单的方法是什么, python 脚本?电容器udf? 有什么想法吗?
我是 tick 环境的新手,所以我真的可以使用一些想法:)
谢谢, 大卫,
找到了完美的方式, 快速简单,使用 kapacitor,甚至不需要创建 udf...
创建此 tick 脚本并将其定义为 kapacitor 任务:
var data = batch
|query(''' SELECT * FROM "My_DB"."My_RP"."My_Measurement" ''')
.period(1d)
.every(30s)
.offset(10d)
data
|shift(10d)
|influxDBOut()
.create()
.database('My_DB')
.measurement('My_Measurement')
就像魔术一样工作!