查询 InfluxDB

使用 from() 函数和 range() 使Flux 从 InfluxDB 查询数据。

from():
bucket 或 bucketID：要查询的 InfluxDB 存储桶名称或存储桶 ID。
range():
start: 返回结果的最早时间。

from(bucket: "example-bucket")
  |> range(start: -1h)
1
2
3

查询 mysql

使用 sql.from() 通过 Flux 查询 SQL 数据库。

import "sql"

sql.from(
    driverName: "mysql",
    dataSourceName: "root:password@tcp(localhost:3306)/test",
    query:"SELECT * FROM user",
)
1
2
3
4
5
6
7

查询 CSV

使用 csv.from() 和 experimental csv.from() 通过 Flux 查询 CSV 数据。 从 URL 、CSV 文件或 CSV 数据。

import "csv"

csvData =
    "
#group,false,false,true,true,true,false,false
#datatype,string,long,string,string,string,long,double
#default,_result,,,,,,
,result,table,dataset,metric,sensorID,timestamp,value
,,0,air-sensors,humidity,TLM0100,1627049400000000000,34.79
,,0,air-sensors,humidity,TLM0100,1627049700000000000,34.65
,,1,air-sensors,humidity,TLM0200,1627049400000000000,35.64
,,1,air-sensors,humidity,TLM0200,1627049700000000000,35.67
"

csv.from(csv: csvData)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15