Flux 入门
Flux 是一种函数式数据脚本语言，旨在将查询、处理、分析和数据操作统一到单个语法中。
Flux 概览
要从概念上理解 Flux 的工作原理，请考虑水处理过程。水从源头抽取，受需求限制，通过一系列站点输送以进行修改（去除沉淀物、净化等），并以可消耗的状态交付。
基本 Flux 查询
与水处理类似，Flux 查询执行以下操作
- 从数据源检索指定量的数据。
- 根据时间和列值过滤数据。
- 将数据处理和塑造成预期的结果。
- 返回结果。
要了解如何从数据源检索数据，请选择数据源：InfluxDB、CSV 或 PostgreSQL。
from(bucket: "example-bucket")
|> range(start: -1d)
|> filter(fn: (r) => r._measurement == "example-measurement")
|> mean()
|> yield(name: "_results")
import "csv"
csv.from(file: "path/to/example/data.csv")
|> range(start: -1d)
|> filter(fn: (r) => r._measurement == "example-measurement")
|> mean()
|> yield(name: "_results")
import "sql"
sql.from(
driverName: "postgres",
dataSourceName: "postgresql://user:password@localhost",
query: "SELECT * FROM TestTable",
)
|> filter(fn: (r) => r.UserID == "123ABC456DEF")
|> mean(column: "purchase_total")
|> yield(name: "_results")
每个示例都包含以下函数（按列出的顺序）
from()从数据源检索数据。- 管道前向运算符 (
|>) 将每个函数的输出作为输入发送到下一个函数。 range()、filter()或两者都用于根据列值过滤数据。mean()计算从数据源返回的值的平均值。yield()向用户产生结果。
有关基本 Flux 查询的详细信息，请参阅Flux 查询基础知识。
此页面是否有帮助？
感谢您的反馈！