How does weighted() work?

Cette page n'est pas encore disponible en français, sa traduction est en cours.
Si vous avez des questions ou des retours sur notre projet de traduction actuel, n'hésitez pas à nous contacter.

Every metrics query has a standard order of evaluation (see the Anatomy of a query for a quick review). For example, the following query is calculated as follows: sum:kubernetes.cpu.requests{*} by {kube_container_name}.rollup(avg, 10)

  1. Time aggregation – Sum the values for each timeseries (defined by a unique tag value combination) in time for each 10s rollup time interval. The number of unique tag value combinations is determined by the most volatile / high granularity tag, let’s say container_id, on this metric.
  2. Then, per kube_container_name (space aggregation), take the sum of all averaged values as a single representative value. The summed values for each kube_container_name is dependent upon the number of unique container_ids there are for each rollup interval.

The weighted() function accounts for the short lifespan of the container_id tag values when summing by kube_container_name for this gauge metric.


Consider this query with the following assumptions:
sum:kubernetes_state.pod.uptime{*} by {version}.rollup(avg, 10)

  • The gauge metric’s submission interval is defined at 10 seconds.
  • A datapoint is graphed every 60 seconds in time.
  • There is a Kubernetes pod with 2 versions at any given time. Each version is labeled with an app and there is only ever 1 version per app.

The raw data over 60 seconds could resemble:

app:a, version:112NANNANNANNANNAN
app:b, version:1NAN121212NANNAN
app:c, version:1NANNANNANNAN1212
app:d, version:212NANNANNANNANNAN
app:e, version:2NAN161616NANNAN
app:f, version:2NANNANNANNAN1818
  1. Time Aggregation – Rolling up data With time aggregation, we’re rolling up data either avg (without weighted) or the proposed weighted average:

    Time aggregation.rollup(avg)With .weighted()
    app:a, version:1122.0
    app:b, version:1126.0
    app:c, version:1124.0
    app:d, version:2122.0
    app:e, version:2168.0
    app:f, version:2186.0
  2. Space Aggregation Finally, the metric is aggregated by version to get the final values below:

    Space aggregation by version.rollup(avg)With .weighted()

The weighted() function remedies any inconsistent behavior with short-lived tags by weighing the values against their submission rate

Further reading

Documentation, liens et articles supplémentaires utiles: