Flux 函数类型和类别

Flux 函数共享一组行为或特性，这些行为或特性定义了函数的工作方式。以下类型和类别列表并非详尽无遗，但涵盖了独特且重要的函数行为。

• 函数类型
• 函数类别

函数类型

• 输入
• 输出
• 转换
  • 聚合
  • 选择器
• 动态查询

输入

Flux 输入函数从数据源返回数据。以下是可用的输入函数

• array.from()
• bigtable.from()
• clickhouse.query()
• csv.from()
• from()
• from()
• generate.from()
• http.get() – (已弃用)
• influxdb.select()
• iox.from()
• iox.sql()
• logql.query_range()
• monitor.logs()
• prometheus.scrape()
• query.inBucket()
• requests.do()
• requests.do() – (已弃用)
• requests.get()
• requests.get() – (已弃用)
• requests.post()
• requests.post() – (已弃用)
• socket.from()
• usage.from()
• v1.json()

输出

Flux 输出函数产生结果或将数据发送到指定的输出目标。以下是可用的输出函数

• experimental.to() – (已弃用)
• influxdb.wideTo()
• kafka.to()
• mqtt.to()
• tickscript.alert()
• to()
• yield()

转换

Flux 转换将表流作为输入，以某种方式转换数据，并输出表流。转换涵盖了广泛的函数，但以下分类突出了与特定转换函数关联的重要行为。

• 聚合
• 选择器

聚合

Flux 聚合函数是转换，以某种方式聚合来自输入表的值。输出表包含一行聚合值。聚合转换为接收的每个输入表输出一个表。

来自聚合函数的每个输出表将

• 包含单个记录。
• 具有与输入表相同的组键。
• 包含聚合列。列标签将与输入表相同。列数据类型取决于特定的聚合操作。如果输入表为空或输入列仅包含 null 值，则列的值将为 null。
• 删除所有列，这些列
  • 不在组键中
  • 不是聚合列

以下是可用的聚合函数

• aggregate.rate()
• aggregateWindow()
• count()
• cov()
• covariance()
• experimental.count()
• experimental.histogramQuantile()
• experimental.integral()
• experimental.mean()
• experimental.mode()
• experimental.quantile()
• experimental.skew()
• experimental.spread()
• experimental.stddev()
• experimental.sum()
• geo.ST_LineString()
• geo.totalDistance()
• integral()
• mean()
• median()
• mode()
• pearsonr()
• prometheus.histogramQuantile()
• quantile()
• reduce()
• skew()
• spread()
• stddev()
• sum()
• timeWeightedAvg()

聚合选择器

以下函数既是聚合函数又是选择器。每个函数在执行聚合操作后返回 n 个值。在本文档中，它们被归类为选择器函数

• highestAverage()
• highestCurrent()
• highestMax()
• lowestAverage()
• lowestCurrent()
• lowestMin()

选择器

Flux 选择器函数是转换，每个输入表返回一个或多个记录。

来自选择器函数的每个输出表将

• 包含一个或多个未修改的记录。
• 具有与输入表相同的组键。

以下是可用的选择器函数

• aggregateWindow()
• bottom()
• distinct()
• experimental.distinct()
• experimental.first()
• experimental.last()
• experimental.max()
• experimental.min()
• experimental.quantile()
• experimental.unique()
• first()
• highestAverage()
• highestCurrent()
• highestMax()
• last()
• limit()
• lowestAverage()
• lowestCurrent()
• lowestMin()
• max()
• median()
• min()
• quantile()
• sample()
• top()
• unique()

选择器和聚合

以下函数既可以用作选择器，也可以用作聚合函数，但在本文档中它们被归类为聚合函数

• median()
• quantile()

动态查询

Flux 动态查询函数从表流中提取表并访问其列和记录。有关推荐用法，请参阅提取标量值。

• findColumn()
• findRecord()
• getColumn()
• getRecord()
• tableFind()

函数类别

以下类别代表高级函数行为。

• 过滤器
• 类型转换
• 测试
• 日期/时间
• 元数据
• 通知端点
• 地理时空

过滤器

过滤器函数迭代并评估每个输入行，以查看其是否与指定的条件匹配。不符合指定条件的行将从输出中删除。以下是可用的过滤器函数

• filter()
• geo.filterRows()
• geo.gridFilter()
• geo.strictFilter()
• hourSelection()
• query.filterFields()
• query.filterMeasurement()
• query.fromRange()
• range()

类型转换

Flux 类型转换函数将标量值或列转换为特定的数据类型。以下是可用的类型转换函数

• array.toBool()
• array.toDuration()
• array.toFloat()
• array.toInt()
• array.toString()
• array.toTime()
• array.toUInt()
• bool()
• bytes()
• duration()
• dynamic.asArray()
• dynamic.dynamic()
• dynamic.jsonEncode()
• dynamic.jsonParse()
• float()
• int()
• iox.sqlInterval()
• json.encode()
• json.parse()
• regexp.compile()
• string()
• time()
• toBool()
• toFloat()
• toInt()
• toString()
• toTime()
• toUInt()
• uint()

测试

Flux 测试函数测试数据的各个方面。测试返回 true 或 false、转换后的表流，或者在失败时返回错误。以下是可用的测试函数

• dynamic.isType()
• testing.assertEmpty
• testing.assertEquals
• testing.assertEqualValues
• testing.assertMatches
• testing.diff
• testing.shouldError
• testing.shouldErrorWithCode
• types.isNumeric()
• types.isType()

日期/时间

Flux 日期/时间函数返回或操作时间或持续时间值。以下是可用的日期/时间函数

• boundaries.friday() – (已弃用)
• boundaries.friday()
• boundaries.monday() – (已弃用)
• boundaries.monday()
• boundaries.month() – (已弃用)
• boundaries.month()
• boundaries.saturday() – (已弃用)
• boundaries.saturday()
• boundaries.sunday() – (已弃用)
• boundaries.sunday()
• boundaries.thursday() – (已弃用)
• boundaries.thursday()
• boundaries.tuesday() – (已弃用)
• boundaries.tuesday()
• boundaries.wednesday() – (已弃用)
• boundaries.wednesday()
• boundaries.week() – (已弃用)
• boundaries.week()
• boundaries.yesterday() – (已弃用)
• boundaries.yesterday()
• date.add()
• date.hour()
• date.microsecond()
• date.millisecond()
• date.minute()
• date.month()
• date.monthDay()
• date.nanosecond()
• date.quarter()
• date.scale()
• date.second()
• date.sub()
• date.time()
• date.truncate()
• date.week()
• date.weekDay()
• date.year()
• date.yearDay()
• experimental.addDuration() – (已弃用)
• experimental.alignTime
• experimental.subDuration() – (已弃用)
• experimental.window()
• hourSelection()
• now()
• system.time()
• timeShift()
• timezone.fixed
• timezone.location
• today()
• truncateTimeColumn()

元数据

Flux 元数据函数从输入流或底层数据源返回元数据。以下是可用的元数据函数

• buckets()
• influxdb.cardinality()
• schema.fieldKeys()
• schema.measurementFieldKeys()
• schema.measurements()
• schema.measurementTagKeys()
• schema.measurementTagValues()
• schema.tagKeys()
• schema.tagValues()
• v1.databases()
• v1.fieldKeys() – (已弃用)
• v1.measurementFieldKeys() – (已弃用)
• v1.measurements() – (已弃用)
• v1.measurementTagKeys() – (已弃用)
• v1.measurementTagValues() – (已弃用)
• v1.tagKeys() – (已弃用)
• v1.tagValues() – (已弃用)

通知端点

Flux 通知端点函数将通知发送到外部端点或服务。以下通知端点函数可用：

• alerta.endpoint()
• bigpanda.endpoint()
• discord.endpoint()
• http.endpoint()
• opsgenie.endpoint()
• pagerduty.endpoint()
• pushbullet.endpoint()
• sensu.endpoint()
• servicenow.endpoint()
• slack.endpoint()
• teams.endpoint()
• telegram.endpoint()
• victorops.endpoint()
• webexteams.endpoint()
• zenoss.endpoint()

地理时空

Flux 地理时序函数旨在处理地理时序数据（随时间变化的地理位置）。以下地理时序函数可用：

• geo.asTracks()
• geo.filterRows()
• geo.getGrid()
• geo.getLevel()
• geo.gridFilter()
• geo.groupByArea()
• geo.s2CellIDToken()
• geo.s2CellLatLon()
• geo.shapeData()
• geo.ST_Contains()
• geo.ST_Distance()
• geo.ST_DWithin()
• geo.ST_Intersects()
• geo.ST_Length()
• geo.ST_LineString()
• geo.stContains()
• geo.stDistance()
• geo.stLength()
• geo.strictFilter()
• geo.toRows()
• geo.totalDistance()