合并节点

stream
  |from()
    .measurement('request_latency')
  |combine(lambda: "service" == 'login', lambda: TRUE)
    .as('login', 'other')
    // points that are within 1 second are considered the same time.
    .tolerance(1s)
    // delimiter for new field and tag names
    .delimiter('.')
  // Change group by to be new other.service tag
  |groupBy('other.service')
  // Both the "value" fields from each data point have been prefixed
  // with the respective names 'login' and 'other'.
  |eval(lambda: "login.value" / "other.value")
    .as('ratio')
  ...

|combine(lambda: TRUE, lambda: TRUE)
  .as('login', 'other')

|combine(lambda: TRUE, lambda: TRUE, lambda: TRUE)
  .as('login', 'other', 'another')

combine.as(names ...string)

combine.delimiter(value string)

combine.max(value int64)

combine.quiet()

combine.tolerance(value time.Duration)

combine|alert()

combine|barrier()

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

combine|changeDetect(field string)

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

combine|count(field string)

combine|cumulativeSum(field string)

    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...

    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...

    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...

combine|deadman(threshold float64, interval time.Duration, expr ...ast.LambdaNode)

combine|default()

combine|delete()

combine|derivative(field string)

combine|difference(field string)

combine|distinct(field string)

combine|ec2Autoscale()

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

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

combine|first(field string)

combine|flatten()

    |groupBy(*)

combine|groupBy(tag ...interface{})

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

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

combine|httpOut(endpoint string)

combine|httpPost(url ...string)

combine|influxDBOut()

combine|join(others ...Node)

combine|k8sAutoscale()

combine|kapacitorLoopback()

combine|last(field string)

combine|log()

combine|mean(field string)

combine|median(field string)

combine|min(field string)

combine|mode(field string)

combine|movingAverage(field string, window int64)

combine|percentile(field string, percentile float64)

combine|sample(rate interface{})

combine|shift(shift time.Duration)

combine|sideload()

combine|spread(field string)

combine|stateCount(expression ast.LambdaNode)

combine|stateDuration(expression ast.LambdaNode)

combine|stats(interval time.Duration)

combine|stddev(field string)

combine|sum(field string)

combine|swarmAutoscale()

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

combine|trickle()

combine|union(node ...Node)

combine|where(expression ast.LambdaNode)

combine|window()