experimental.chain() 函数
experimental.chain() 在任何时候都可能更改。
experimental.chain() 在单个 Flux 脚本中顺序运行两个查询，并输出第二个查询的结果。
Flux 通常在单个脚本中并行执行多个查询。顺序运行查询可确保第二个查询对第一个查询结果的任何依赖关系都得到满足。
适用用例
在单个 Flux 脚本中写入 InfluxDB bucket 并查询写入的数据。
_注意：
experimental.chain()不保证写入 InfluxDB 的数据可以立即查询。数据写入时间和可查询时间之间的延迟可能会导致使用experimental.chain()的查询失败。在测试场景中顺序执行查询。
函数类型签名
(first: stream[A], second: stream[B]) => stream[B] where A: Record, B: Record
有关更多信息，请参阅函数类型签名。
参数
first
(必需) 要执行的第一个查询。
second
(必需) 要执行的第二个查询。
示例
写入 bucket 并查询写入的数据
import "experimental"
downsampled_max =
from(bucket: "example-bucket-1")
|> range(start: -1d)
|> filter(fn: (r) => r._measurement == "example-measurement")
|> aggregateWindow(every: 1h, fn: max)
|> to(bucket: "downsample-1h-max", org: "example-org")
average_max =
from(bucket: "downsample-1h-max")
|> range(start: -1d)
|> filter(fn: (r) => r.measurement == "example-measurement")
|> mean()
experimental.chain(first: downsampled_max, second: average_max)
此页是否对您有帮助？
感谢您的反馈！