文档文档

StateCountNode

stateCount 节点计算给定状态下连续点的数量。状态通过 lambda 表达式定义。

对于每个 lambda 表达式评估为 true 的连续点,状态计数都会递增。这对于流和批处理都是如此。对于流,每当一个点评估为 false 时,状态计数都会重置。在处理批处理时,状态计数在批处理结束时重置。

状态计数将作为额外的 int64 字段添加到每个点。如果表达式评估为 false,则该值为 -1。如果表达式在评估期间生成错误,则该点将被丢弃,并且不影响状态计数。

示例

stream
  |from()
    .measurement('cpu')
  |where(lambda: "cpu" == 'cpu-total')
  |groupBy('host')
  |stateCount(lambda: "usage_idle" <= 10)
  |alert()
    // Warn after 1 point
    .warn(lambda: "state_count" >= 1)
    // Critical after 5 points
    .crit(lambda: "state_count" >= 5)

构造函数

链式方法描述
stateCount ( expression ast.LambdaNode)创建一个节点,用于跟踪给定状态下连续点的数量。

属性方法

设置器描述
as ( value string)结果持续时间字段的新名称。默认值: ‘state_count’
quiet ( )抑制来自此节点的所有错误日志记录事件。

链式方法

Alert, Barrier, Bottom, ChangeDetect, Combine, Count, CumulativeSum, Deadman, Default, Delete, Derivative, Difference, Distinct, Ec2Autoscale, Elapsed, Eval, First, Flatten, GroupBy, HoltWinters, HoltWintersWithFit, HttpOut, HttpPost, InfluxDBOut, Join, K8sAutoscale, KapacitorLoopback, Last, Log, Max, Mean, Median, Min, Mode, MovingAverage, Percentile, Sample, Shift, Sideload, Spread, StateCount, StateDuration, Stats, Stddev, Sum, SwarmAutoscale, Top, Trickle, Union, Where, Window


属性

属性方法修改调用节点上的状态。它们不会向管道添加另一个节点,并且始终返回对调用节点的引用。属性方法使用 . 运算符标记。

As

结果持续时间字段的新名称。默认值: ‘state_count’

stateCount.as(value string)

Quiet

抑制来自此节点的所有错误日志记录事件。

stateCount.quiet()

链式方法

链式方法在管道中创建一个新节点作为调用节点的子节点。它们不会修改调用节点。链式方法使用 | 运算符标记。

Alert

创建一个警报节点,可以触发警报。

stateCount|alert()

返回值: AlertNode

Barrier

创建一个新的屏障节点,定期发出 BarrierMessage。

每个周期持续时间将发出一个 BarrierMessage。

stateCount|barrier()

返回值: BarrierNode

Bottom

field 选择底部 num 个点,并按任何额外的标签或字段排序。

stateCount|bottom(num int64, field string, fieldsAndTags ...string)

返回值: InfluxQLNode

ChangeDetect

创建一个新节点,仅当新点与前一个点不同时才发出新点。

stateCount|changeDetect(field string)

返回值: ChangeDetectNode

Combine

将此节点与其自身合并。数据按时间戳合并。

stateCount|combine(expressions ...ast.LambdaNode)

返回值: CombineNode

Count

计算点的数量。

stateCount|count(field string)

返回值: InfluxQLNode

CumulativeSum

计算接收到的每个点的累积和。对于收集的每个点,都会发出一个点。

stateCount|cumulativeSum(field string)

返回值: InfluxQLNode

Deadman

用于创建低吞吐量警报的辅助函数,又名 deadman’s switch。

  • 阈值:如果吞吐量降至低于阈值(点/间隔),则触发警报。
  • 间隔:检查吞吐量的频率。
  • 表达式:要评估的可选表达式列表。对于一天中的时间警报很有用。

示例

    var data = stream
        |from()...
    // Trigger critical alert if the throughput drops below 100 points per 10s and checked every 10s.
    data
        |deadman(100.0, 10s)
    //Do normal processing of data
    data...

以上等同于此示例

    var data = stream
        |from()...
    // Trigger critical alert if the throughput drops below 100 points per 10s and checked every 10s.
    data
        |stats(10s)
            .align()
        |derivative('emitted')
            .unit(10s)
            .nonNegative()
        |alert()
            .id('node \'stream0\' in task \'{{ .TaskName }}\'')
            .message('{{ .ID }} is {{ if eq .Level "OK" }}alive{{ else }}dead{{ end }}: {{ index .Fields "emitted" | printf "%0.3f" }} points/10s.')
            .crit(lambda: "emitted" <= 100.0)
    //Do normal processing of data
    data...

idmessage 警报属性可以通过 ‘deadman’ 配置部分全局配置。

由于 AlertNode 是最后一部分,因此可以像往常一样进一步修改。示例

    var data = stream
        |from()...
    // Trigger critical alert if the throughput drops below 100 points per 10s and checked every 10s.
    data
        |deadman(100.0, 10s)
            .slack()
            .channel('#dead_tasks')
    //Do normal processing of data
    data...

您可以指定其他 lambda 表达式以进一步约束何时触发 deadman’s switch。示例

    var data = stream
        |from()...
    // Trigger critical alert if the throughput drops below 100 points per 10s and checked every 10s.
    // Only trigger the alert if the time of day is between 8am-5pm.
    data
        |deadman(100.0, 10s, lambda: hour("time") >= 8 AND hour("time") <= 17)
    //Do normal processing of data
    data...
stateCount|deadman(threshold float64, interval time.Duration, expr ...ast.LambdaNode)

返回值: AlertNode

Default

创建一个节点,可以为缺失的标签或字段设置默认值。

stateCount|default()

返回值: DefaultNode

Delete

创建一个可以删除标签或字段的节点。

stateCount|delete()

返回值: DeleteNode

Derivative

创建一个新节点,计算相邻点的导数。

stateCount|derivative(field string)

返回值: DerivativeNode

Difference

计算点之间的差值,与经过的时间无关。

stateCount|difference(field string)

返回值: InfluxQLNode

Distinct

生成仅包含唯一值的批处理。

stateCount|distinct(field string)

返回值: InfluxQLNode

Ec2Autoscale

创建一个节点,可以为 ec2 自动伸缩组触发自动伸缩事件。

stateCount|ec2Autoscale()

返回值: Ec2AutoscaleNode

Elapsed

计算点之间经过的时间。

stateCount|elapsed(field string, unit time.Duration)

返回值: InfluxQLNode

Eval

创建一个 eval 节点,它将评估给定的转换函数到每个数据点。可以提供表达式列表,并将按给定的顺序进行评估。结果可用于后续表达式。

stateCount|eval(expressions ...ast.LambdaNode)

返回值: EvalNode

First

选择第一个点。

stateCount|first(field string)

返回值: InfluxQLNode

Flatten

将时间相似的点扁平化为单个点。

stateCount|flatten()

返回值: FlattenNode

GroupBy

按一组标签对数据进行分组。

可以传递字面量 * 以按所有维度分组。示例

    |groupBy(*)
stateCount|groupBy(tag ...interface{})

返回值: GroupByNode

HoltWinters

计算数据集的 Holt-Winters 预测。

stateCount|holtWinters(field string, h int64, m int64, interval time.Duration)

返回值: InfluxQLNode

HoltWintersWithFit

计算数据集的 Holt-Winters 预测。除了预测数据外,此方法还输出用于拟合数据的所有点。

stateCount|holtWintersWithFit(field string, h int64, m int64, interval time.Duration)

返回值: InfluxQLNode

HttpOut

创建一个 HTTP 输出节点,该节点缓存其接收到的最新数据。缓存的数据在给定的端点可用。端点是运行任务的 API 端点的相对路径。例如,如果任务端点在 `/kapacitor/v1/tasks/<task_id>`,而端点是 `top10`,则可以从 `/kapacitor/v1/tasks/<task_id>/top10` 请求数据。

stateCount|httpOut(endpoint string)

返回值: HTTPOutNode

HttpPost

创建一个 HTTP Post 节点,该节点将接收到的数据 POST 到提供的 HTTP 端点。HttpPost 期望 0 或 1 个参数。如果提供 0 个参数,则必须指定一个端点属性方法。

stateCount|httpPost(url ...string)

返回值: HTTPPostNode

InfluxDBOut

创建一个 influxdb 输出节点,该节点将传入的数据存储到 InfluxDB 中。

stateCount|influxDBOut()

返回值: InfluxDBOutNode

Join

将此节点与其他节点连接。数据按时间戳连接。

stateCount|join(others ...Node)

返回值: JoinNode

K8sAutoscale

创建一个节点,可以为 kubernetes 集群触发自动伸缩事件。

stateCount|k8sAutoscale()

返回值: K8sAutoscaleNode

KapacitorLoopback

创建一个 kapacitor 回环节点,该节点将数据作为流发送回 Kapacitor。

stateCount|kapacitorLoopback()

返回值: KapacitorLoopbackNode

Last

选择最后一个点。

stateCount|last(field string)

返回值: InfluxQLNode

Log

创建一个节点,记录其接收到的所有数据。

stateCount|log()

返回值: LogNode

Max

选择最大值点。

stateCount|max(field string)

返回值: InfluxQLNode

Mean

计算数据的平均值。

stateCount|mean(field string)

返回值: InfluxQLNode

Median

计算数据的中位数。

注意: 此方法不是选择器。如果您想要中位数点,请使用 .percentile(field, 50.0)

stateCount|median(field string)

返回值: InfluxQLNode

Min

选择最小值点。

stateCount|min(field string)

返回值: InfluxQLNode

Mode

计算数据的众数。

stateCount|mode(field string)

返回值: InfluxQLNode

MovingAverage

计算最后窗口点的移动平均值。在窗口满之前不会发出任何点。

stateCount|movingAverage(field string, window int64)

返回值: InfluxQLNode

Percentile

选择给定百分位数的点。这是一个选择器函数,不会在点之间执行插值。

stateCount|percentile(field string, percentile float64)

返回值: InfluxQLNode

Sample

创建一个新节点,对传入的点或批处理进行采样。

每指定的计数或持续时间将发出一个点。

stateCount|sample(rate interface{})

返回值: SampleNode

Shift

创建一个新节点,及时移动传入的点或批处理。

stateCount|shift(shift time.Duration)

返回值: ShiftNode

Sideload

创建一个可以从外部源加载数据的节点。

stateCount|sideload()

返回值: SideloadNode

Spread

计算 minmax 点之间的差值。

stateCount|spread(field string)

返回值: InfluxQLNode

StateCount

创建一个节点,用于跟踪给定状态下连续点的数量。

stateCount|stateCount(expression ast.LambdaNode)

返回值: StateCountNode

StateDuration

创建一个节点,跟踪给定状态下的持续时间。

stateCount|stateDuration(expression ast.LambdaNode)

返回值: StateDurationNode

Stats

创建一个新的数据流,其中包含节点的内部统计信息。间隔表示基于实时发出统计信息的频率。这意味着间隔时间独立于源节点正在接收的数据点的时间。

stateCount|stats(interval time.Duration)

返回值: StatsNode

Stddev

计算标准差。

stateCount|stddev(field string)

返回值: InfluxQLNode

Sum

计算所有值的总和。

stateCount|sum(field string)

返回值: InfluxQLNode

SwarmAutoscale

创建一个节点,可以为 Docker swarm 集群触发自动伸缩事件。

stateCount|swarmAutoscale()

返回值: SwarmAutoscaleNode

Top

field 选择顶部 num 个点,并按任何额外的标签或字段排序。

stateCount|top(num int64, field string, fieldsAndTags ...string)

返回值: InfluxQLNode

Trickle

创建一个新节点,将批处理数据转换为流数据。

stateCount|trickle()

返回值: TrickleNode

Union

执行此节点和所有其他给定节点的并集。

stateCount|union(node ...Node)

返回值: UnionNode

Where

创建一个新节点,通过给定的表达式过滤数据流。

stateCount|where(expression ast.LambdaNode)

返回值: WhereNode

Window

创建一个新节点,按时间窗口化流。

注意:窗口只能应用于流边缘。

stateCount|window()

返回值: WindowNode


此页是否对您有帮助?

感谢您的反馈!


Flux 的未来

Flux 即将进入维护模式。您可以继续像现在这样使用它,而无需对您的代码进行任何更改。

阅读更多

现已全面上市

InfluxDB 3 核心版和企业版

快速启动。更快扩展。

获取更新

InfluxDB 3 核心版是一个开源、高速、近实时数据引擎,可实时收集和处理数据,并将其持久化到本地磁盘或对象存储。InfluxDB 3 企业版建立在核心版的基础上,增加了高可用性、只读副本、增强的安全性以及数据压缩,以实现更快的查询和优化的存储。InfluxDB 3 企业版免费层可用于非商业家庭或业余爱好者使用。

有关更多信息,请查看