69 lines
1.8 KiB
Markdown
69 lines
1.8 KiB
Markdown
---
|
|
title: Query cumulative sum
|
|
seotitle: Query cumulative sum in Flux
|
|
list_title: Cumulative sum
|
|
description: >
|
|
Use the `cumulativeSum()` function to calculate a running total of values.
|
|
weight: 10
|
|
menu:
|
|
enterprise_influxdb_v1:
|
|
parent: Query with Flux
|
|
name: Cumulative sum
|
|
list_query_example: cumulative_sum
|
|
canonical: /influxdb/v2/query-data/flux/cumulativesum/
|
|
---
|
|
|
|
Use the [`cumulativeSum()` function](/flux/v0/stdlib/universe/cumulativesum/)
|
|
to calculate a running total of values.
|
|
`cumulativeSum` sums the values of subsequent records and returns each row updated with the summed total.
|
|
|
|
{{< flex >}}
|
|
{{% flex-content "half" %}}
|
|
**Given the following input table:**
|
|
|
|
| _time | _value |
|
|
| ----- |:------:|
|
|
| 0001 | 1 |
|
|
| 0002 | 2 |
|
|
| 0003 | 1 |
|
|
| 0004 | 3 |
|
|
{{% /flex-content %}}
|
|
{{% flex-content "half" %}}
|
|
**`cumulativeSum()` returns:**
|
|
|
|
| _time | _value |
|
|
| ----- |:------:|
|
|
| 0001 | 1 |
|
|
| 0002 | 3 |
|
|
| 0003 | 4 |
|
|
| 0004 | 7 |
|
|
{{% /flex-content %}}
|
|
{{< /flex >}}
|
|
|
|
{{% note %}}
|
|
The examples below use the [example data variable](/enterprise_influxdb/v1/flux/guides/#example-data-variable).
|
|
{{% /note %}}
|
|
|
|
##### Calculate the running total of values
|
|
```js
|
|
data
|
|
|> cumulativeSum()
|
|
```
|
|
|
|
## Use cumulativeSum() with aggregateWindow()
|
|
[`aggregateWindow()`](/flux/v0/stdlib/universe/aggregatewindow/)
|
|
segments data into windows of time, aggregates data in each window into a single
|
|
point, then removes the time-based segmentation.
|
|
It is primarily used to downsample data.
|
|
|
|
`aggregateWindow()` expects an aggregate function that returns a single row for each time window.
|
|
To use `cumulativeSum()` with `aggregateWindow`, use `sum` in `aggregateWindow()`,
|
|
then calculate the running total of the aggregate values with `cumulativeSum()`.
|
|
|
|
<!-- -->
|
|
```js
|
|
data
|
|
|> aggregateWindow(every: 5m, fn: sum)
|
|
|> cumulativeSum()
|
|
```
|