Merge branch 'late-arriving-data' of https://github.com/Anaisdg/docs-v2 into late-arriving-data
commit
d8f9cedbd6
|
|
@ -25,7 +25,9 @@ hrefTargetBlank = true
|
|||
smartDashes = false
|
||||
|
||||
[taxonomies]
|
||||
"influxdb/v2.2/tag" = "influxdb/v2.1/tags"
|
||||
"influxdb/v2.4/tag" = "influxdb/v2.4/tags"
|
||||
"influxdb/v2.3/tag" = "influxdb/v2.3/tags"
|
||||
"influxdb/v2.2/tag" = "influxdb/v2.2/tags"
|
||||
"influxdb/v2.1/tag" = "influxdb/v2.1/tags"
|
||||
"influxdb/v2.0/tag" = "influxdb/v2.0/tags"
|
||||
"influxdb/cloud/tag" = "influxdb/cloud/tags"
|
||||
|
|
@ -35,3 +37,13 @@ smartDashes = false
|
|||
[markup.goldmark]
|
||||
[markup.goldmark.renderer]
|
||||
unsafe = true
|
||||
|
||||
[privacy]
|
||||
[privacy.googleAnalytics]
|
||||
anonymizeIP = false
|
||||
disable = false
|
||||
respectDoNotTrack = true
|
||||
useSessionStorage = false
|
||||
[privacy.youtube]
|
||||
disable = false
|
||||
privacyEnhanced = true
|
||||
|
|
|
|||
|
|
@ -16,28 +16,43 @@ Dashboards in Chronograf can be cloned (or copied) to be used to create a dashbo
|
|||
|
||||
### To clone a dashboard
|
||||
|
||||
1. On the **Dashboards** page, hover your cursor over the listing of the dashboard that you want to clone and click the **Clone** button that appears.
|
||||
On the **Dashboards** page, hover your cursor over the listing of the dashboard that you want to clone and click the **Clone** button that appears.
|
||||
|
||||

|
||||

|
||||
|
||||
The cloned dashboard opens and displays the name of the original dashboard with `(clone)` after it.
|
||||
The cloned dashboard opens and displays the name of the original dashboard with `(clone)` after it.
|
||||
|
||||

|
||||

|
||||
|
||||
You can now change the dashboard name and customize the dashboard.
|
||||
You can now change the dashboard name and customize the dashboard.
|
||||
|
||||
## Clone cells
|
||||
|
||||
Cells in Chronograf dashboards can be cloned, or copied, to quickly create a cell copy that can be edited for another use.
|
||||
Cells in Chronograf dashboards can be cloned or copied to quickly create a cell copy that can be edited for another use.
|
||||
|
||||
### To clone a cell
|
||||
|
||||
1. On the dashboard cell that you want to make a copy of, click the **Clone** icon and then confirm by clicking **Clone Cell**.
|
||||
|
||||

|
||||

|
||||
|
||||
2. The cloned cell appears in the dashboard displaying the nameof the original cell with `(clone)` after it.
|
||||
|
||||

|
||||

|
||||
|
||||
You can now change the cell name and customize the cell.
|
||||
You can now change the cell name and customize the cell.
|
||||
|
||||
{{% note %}}
|
||||
#### Cells can only be cloned to the current dashboard
|
||||
|
||||
Dashboard cells can only be clone to the current dashboard and can not be cloned to another dashboard.
|
||||
To clone a cell to another dashboard:
|
||||
|
||||
1. Hover over the cell you want to clone, click the **{{< icon "pencil" "v1" >}}**
|
||||
icon, and then select **Configure**.
|
||||
2. Copy the cell query.
|
||||
3. Open the dashboard you want to clone the cell to.
|
||||
4. Click **{{< icon "add-cell" "v2" >}} Add Cell** to create a new cell.
|
||||
5. Paste your copied query into the new cell.
|
||||
6. Duplicate all the visualizations settings from your cloned cell.
|
||||
{{% /note %}}
|
||||
|
|
@ -8,3 +8,6 @@ menu:
|
|||
---
|
||||
|
||||
Download the latest Chronograf release at the [InfluxData download page](https://portal.influxdata.com/downloads).
|
||||
Click **Are you interested in InfluxDB 1.x Open Source?** to expand the 1.x options. Scroll to the **Chronograf** section and select your desired Chronograf version and operating system. Execute the provided download commands.
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -25,7 +25,7 @@ Chronograf is the user interface for InfluxData's [TICK stack](https://www.influ
|
|||
|
||||
The latest Chronograf builds are available on InfluxData's [Downloads page](https://portal.influxdata.com/downloads).
|
||||
|
||||
1. Choose the download link for your operating system.
|
||||
1. On the Downloads page, scroll to the bottom and click **Are you interested in InfluxDB 1.x Open Source?** to expand the 1.x options. Scroll to the **Chronograf** section and select your desired Chronograf version and operating system. Execute the provided download commands.
|
||||
|
||||
{{% note %}}
|
||||
If your download includes a TAR package, save the underlying datastore `chronograf-v1.db` in directory outside of where you start Chronograf. This preserves and references your existing datastore, including configurations and dashboards, when you download future versions.
|
||||
|
|
|
|||
|
|
@ -16,28 +16,44 @@ Dashboards in Chronograf can be cloned (or copied) to be used to create a dashbo
|
|||
|
||||
### To clone a dashboard
|
||||
|
||||
1. On the **Dashboards** page, hover your cursor over the listing of the dashboard that you want to clone and click the **Clone** button that appears.
|
||||
On the **Dashboards** page, hover your cursor over the listing of the dashboard that you want to clone and click the **Clone** button that appears.
|
||||
|
||||

|
||||

|
||||
|
||||
The cloned dashboard opens and displays the name of the original dashboard with `(clone)` after it.
|
||||
The cloned dashboard opens and displays the name of the original dashboard with `(clone)` after it.
|
||||
|
||||

|
||||

|
||||
|
||||
You can now change the dashboard name and customize the dashboard.
|
||||
You can now change the dashboard name and customize the dashboard.
|
||||
|
||||
## Clone cells
|
||||
|
||||
Cells in Chronograf dashboards can be cloned, or copied, to quickly create a cell copy that can be edited for another use.
|
||||
Cells in Chronograf dashboards can be cloned or copied to quickly create a cell copy that can be edited for another use.
|
||||
|
||||
### To clone a cell
|
||||
|
||||
1. On the dashboard cell that you want to make a copy of, click the **Clone** icon and then confirm by clicking **Clone Cell**.
|
||||
|
||||

|
||||

|
||||
|
||||
2. The cloned cell appears in the dashboard displaying the nameof the original cell with `(clone)` after it.
|
||||
|
||||

|
||||

|
||||
|
||||
You can now change the cell name and customize the cell.
|
||||
|
||||
{{% note %}}
|
||||
#### Cells can only be cloned to the current dashboard
|
||||
|
||||
Dashboard cells can only be clone to the current dashboard and can not be cloned to another dashboard.
|
||||
To clone a cell to another dashboard:
|
||||
|
||||
1. Hover over the cell you want to clone, click the **{{< icon "pencil" "v1" >}}**
|
||||
icon, and then select **Configure**.
|
||||
2. Copy the cell query.
|
||||
3. Open the dashboard you want to clone the cell to.
|
||||
4. Click **{{< icon "add-cell" "v2" >}} Add Cell** to create a new cell.
|
||||
5. Paste your copied query into the new cell.
|
||||
6. Duplicate all the visualizations settings from your cloned cell.
|
||||
{{% /note %}}
|
||||
|
||||
You can now change the cell name and customize the cell.
|
||||
|
|
|
|||
|
|
@ -88,6 +88,7 @@ group key instances from matching.
|
|||
- [table is missing column \'\<column\>\'](#table-is-missing-column-column)
|
||||
- [table is missing label \<label\>](#table-is-missing-label-label)
|
||||
- [record is missing label \<label\>](#record-is-missing-label-label)
|
||||
- [cannot join on an empty table](#cannot-join-on-an-empty-table)
|
||||
|
||||
### table is missing column `'<column>'`
|
||||
|
||||
|
|
@ -184,3 +185,31 @@ Ensure the columns that you're using in the `as` output function to assign
|
|||
values to the output actually exist in the input streams.
|
||||
{{% /flex-content %}}
|
||||
{{< /flex >}}
|
||||
|
||||
---
|
||||
|
||||
### cannot join on an empty table
|
||||
|
||||
##### Error message
|
||||
```js
|
||||
error preparing <left or right> side of join: cannot join on an empty table
|
||||
```
|
||||
|
||||
{{< flex >}}
|
||||
{{% flex-content %}}
|
||||
#### Cause {#cause-e3}
|
||||
|
||||
**One of your input streams is an empty stream of tables**.
|
||||
Functions in the join package error when one or both of the input
|
||||
streams are empty.
|
||||
{{% /flex-content %}}
|
||||
{{% flex-content %}}
|
||||
#### Solution {#solution-e3}
|
||||
|
||||
Use [`array.from()`](/flux/v0.x/stdlib/array/from/) and
|
||||
[`union()`](/flux/v0.x/stdlib/universe/union/) to insert a dummy table into each
|
||||
stream that you filter out after the join operation.
|
||||
The dummy table needs to include all group key columns of the stream it is unioned with.
|
||||
|
||||
{{% /flex-content %}}
|
||||
{{< /flex >}}
|
||||
|
|
|
|||
|
|
@ -10,6 +10,36 @@ aliases:
|
|||
- /influxdb/cloud/reference/release-notes/flux/
|
||||
---
|
||||
|
||||
## v0.185.0 [2022-10-03]
|
||||
|
||||
### Features
|
||||
- Add dynamic type.
|
||||
- Add dynamic wrapper function.
|
||||
- Enable codespan formatting for errors via feature flags.
|
||||
|
||||
### Bug fixes
|
||||
- Pass context in the `Run` source helper.
|
||||
- Handle null vector inputs for `_vecFloat`.
|
||||
- Remove broken `contrib` packages:
|
||||
- contrib/jsternberg/aggregate
|
||||
- contrib/jsternberg/math
|
||||
|
||||
---
|
||||
|
||||
## v0.184.2 [2022-09-26]
|
||||
|
||||
### Bug fixes
|
||||
- Remove the `stacker` dependency.
|
||||
- Skip strict _null_ logical evaluator.
|
||||
|
||||
---
|
||||
|
||||
## v0.184.1 [2022-09-21]
|
||||
|
||||
- _Internal code cleanup._
|
||||
|
||||
---
|
||||
|
||||
## v0.184.0 [2022-09-21]
|
||||
|
||||
### Breaking changes
|
||||
|
|
|
|||
|
|
@ -1,54 +0,0 @@
|
|||
---
|
||||
title: aggregate package
|
||||
description: >
|
||||
The `aggregate` package provides an API for computing multiple aggregates over multiple columns within the same table stream.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: aggregate
|
||||
parent: contrib/jsternberg
|
||||
identifier: contrib/jsternberg/aggregate
|
||||
weight: 31
|
||||
cascade:
|
||||
|
||||
introduced: 0.77.0
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the comments above the package
|
||||
declaration in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/aggregate/aggregate.flux
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
The `aggregate` package provides an API for computing multiple aggregates over multiple columns within the same table stream.
|
||||
Import the `contrib/jsternberg/aggregate` package:
|
||||
|
||||
```js
|
||||
import "contrib/jsternberg/aggregate"
|
||||
```
|
||||
|
||||
## Constants
|
||||
|
||||
```js
|
||||
aggregate.none
|
||||
aggregate.null
|
||||
```
|
||||
|
||||
- **aggregate.none** is a sentinel value for fill that will skip
|
||||
emitting a row if there are no values for an interval.
|
||||
- **aggregate.null** is a sentinel value for fill that will fill
|
||||
in a null value if there were no values for an interval.
|
||||
|
||||
|
||||
## Functions
|
||||
|
||||
{{< children type="functions" show="pages" >}}
|
||||
|
|
@ -1,63 +0,0 @@
|
|||
---
|
||||
title: aggregate.count() function
|
||||
description: >
|
||||
`aggregate.count()` constructs a count aggregate for the column.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: aggregate.count
|
||||
parent: contrib/jsternberg/aggregate
|
||||
identifier: contrib/jsternberg/aggregate/count
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/aggregate/aggregate.flux#L162-L170
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`aggregate.count()` constructs a count aggregate for the column.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(
|
||||
?column: A,
|
||||
?fill: B,
|
||||
) => {
|
||||
reduce: (state: int, values: [E]) => int,
|
||||
init: (values: [D]) => int,
|
||||
fill: B,
|
||||
compute: (state: C) => C,
|
||||
column: A,
|
||||
}
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### column
|
||||
|
||||
Name of the column to aggregate.
|
||||
|
||||
|
||||
|
||||
### fill
|
||||
|
||||
When set, value to replace missing values.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,91 +0,0 @@
|
|||
---
|
||||
title: aggregate.define() function
|
||||
description: >
|
||||
`aggregate.define()` constructs an aggregate function record.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: aggregate.define
|
||||
parent: contrib/jsternberg/aggregate
|
||||
identifier: contrib/jsternberg/aggregate/define
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/aggregate/aggregate.flux#L109-L117
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`aggregate.define()` constructs an aggregate function record.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(
|
||||
compute: A,
|
||||
init: B,
|
||||
reduce: C,
|
||||
?fill: D,
|
||||
) => (
|
||||
?column: E,
|
||||
?fill: F,
|
||||
) => {
|
||||
reduce: C,
|
||||
init: B,
|
||||
fill: F,
|
||||
compute: A,
|
||||
column: E,
|
||||
}
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### init
|
||||
({{< req >}})
|
||||
Function to compute the initial state of the
|
||||
output. This can return either the final aggregate or a
|
||||
temporary state object that can be used to compute the
|
||||
final aggregate. The `values` parameter will always be a
|
||||
non-empty array of values from the specified column.
|
||||
|
||||
|
||||
|
||||
### reduce
|
||||
({{< req >}})
|
||||
Function that takes in another buffer of values
|
||||
and the current state of the aggregate and computes
|
||||
the updated state.
|
||||
|
||||
|
||||
|
||||
### compute
|
||||
({{< req >}})
|
||||
Function that takes the state and computes the final aggregate.
|
||||
|
||||
|
||||
|
||||
### fill
|
||||
|
||||
Value passed to `fill()`. If present, the fill value determines what
|
||||
the aggregate does when there are no values.
|
||||
This can either be a value or one of the predefined
|
||||
identifiers, `null` or `none`.
|
||||
This value must be the same type as the value return from
|
||||
compute.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,63 +0,0 @@
|
|||
---
|
||||
title: aggregate.max() function
|
||||
description: >
|
||||
`aggregate.max()` constructs a max aggregate or selector for the column.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: aggregate.max
|
||||
parent: contrib/jsternberg/aggregate
|
||||
identifier: contrib/jsternberg/aggregate/max
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/aggregate/aggregate.flux#L141-L141
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`aggregate.max()` constructs a max aggregate or selector for the column.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(
|
||||
?column: A,
|
||||
?fill: B,
|
||||
) => {
|
||||
reduce: (state: D, values: [D]) => D,
|
||||
init: (values: [D]) => D,
|
||||
fill: B,
|
||||
compute: (state: C) => C,
|
||||
column: A,
|
||||
} where D: Numeric
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### column
|
||||
|
||||
Name of the column to aggregate.
|
||||
|
||||
|
||||
|
||||
### fill
|
||||
|
||||
When set, value to replace missing values.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,63 +0,0 @@
|
|||
---
|
||||
title: aggregate.mean() function
|
||||
description: >
|
||||
`aggregate.mean()` constructs a mean aggregate for the column.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: aggregate.mean
|
||||
parent: contrib/jsternberg/aggregate
|
||||
identifier: contrib/jsternberg/aggregate/mean
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/aggregate/aggregate.flux#L177-L183
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`aggregate.mean()` constructs a mean aggregate for the column.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(
|
||||
?column: A,
|
||||
?fill: B,
|
||||
) => {
|
||||
reduce: (state: {G with sum: H, count: int}, values: [H]) => {sum: H, count: int},
|
||||
init: (values: [F]) => {sum: F, count: int},
|
||||
fill: B,
|
||||
compute: (state: {C with sum: E, count: D}) => float,
|
||||
column: A,
|
||||
} where F: Numeric, H: Addable + Numeric
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### column
|
||||
|
||||
Name of the column to aggregate.
|
||||
|
||||
|
||||
|
||||
### fill
|
||||
|
||||
When set, value to replace missing values.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,63 +0,0 @@
|
|||
---
|
||||
title: aggregate.min() function
|
||||
description: >
|
||||
`aggregate.min()` constructs a min aggregate or selector for the column.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: aggregate.min
|
||||
parent: contrib/jsternberg/aggregate
|
||||
identifier: contrib/jsternberg/aggregate/min
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/aggregate/aggregate.flux#L134-L134
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`aggregate.min()` constructs a min aggregate or selector for the column.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(
|
||||
?column: A,
|
||||
?fill: B,
|
||||
) => {
|
||||
reduce: (state: D, values: [D]) => D,
|
||||
init: (values: [D]) => D,
|
||||
fill: B,
|
||||
compute: (state: C) => C,
|
||||
column: A,
|
||||
} where D: Numeric
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### column
|
||||
|
||||
Name of the column to aggregate.
|
||||
|
||||
|
||||
|
||||
### fill
|
||||
|
||||
When set, value to replace missing values.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,63 +0,0 @@
|
|||
---
|
||||
title: aggregate.sum() function
|
||||
description: >
|
||||
`aggregate.sum()` constructs a sum aggregate for the column.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: aggregate.sum
|
||||
parent: contrib/jsternberg/aggregate
|
||||
identifier: contrib/jsternberg/aggregate/sum
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/aggregate/aggregate.flux#L148-L155
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`aggregate.sum()` constructs a sum aggregate for the column.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(
|
||||
?column: A,
|
||||
?fill: B,
|
||||
) => {
|
||||
reduce: (state: E, values: [E]) => E,
|
||||
init: (values: [D]) => D,
|
||||
fill: B,
|
||||
compute: (state: C) => C,
|
||||
column: A,
|
||||
} where D: Numeric, E: Addable + Numeric
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### column
|
||||
|
||||
Name of the column to aggregate.
|
||||
|
||||
|
||||
|
||||
### fill
|
||||
|
||||
When set, value to replace missing values.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,126 +0,0 @@
|
|||
---
|
||||
title: aggregate.table() function
|
||||
description: >
|
||||
`aggregate.table()` will aggregate columns and create tables with a single
|
||||
row containing the aggregated value.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: aggregate.table
|
||||
parent: contrib/jsternberg/aggregate
|
||||
identifier: contrib/jsternberg/aggregate/table
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/aggregate/aggregate.flux#L54-L54
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`aggregate.table()` will aggregate columns and create tables with a single
|
||||
row containing the aggregated value.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(<-tables: stream[B], columns: A) => stream[C] where A: Record, B: Record, C: Record
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### tables
|
||||
|
||||
Input data. Default is piped-forward data (`<-`).
|
||||
|
||||
|
||||
|
||||
### columns
|
||||
({{< req >}})
|
||||
Columns to aggregate and which aggregate method to use.
|
||||
|
||||
Columns is a record where the key is a column name and the value is an aggregate record.
|
||||
The aggregate record is composed of at least the following required attributes:
|
||||
- **column**: Input column name (string).
|
||||
- **init**: A function to compute the initial state of the
|
||||
output. This can return either the final aggregate or a
|
||||
temporary state object that can be used to compute the
|
||||
final aggregate. The `values` parameter will always be a
|
||||
non-empty array of values from the specified column.
|
||||
For example: `(values) => state`.
|
||||
- **reduce**: A function that takes in another buffer of values
|
||||
and the current state of the aggregate and computes
|
||||
the updated state.
|
||||
For example: `(values, state) => state`.
|
||||
- **compute**: A function that takes the state and computes the final
|
||||
aggregate. For example, `(state) => value`.
|
||||
- **fill**: The value passed to `fill()`. If present, the fill value
|
||||
determines what the aggregate does when there are no values.
|
||||
This can either be a value or one of the predefined
|
||||
identifiers of `null` or `none`.
|
||||
This value must be the same type as the value return from
|
||||
`compute`.
|
||||
|
||||
|
||||
## Examples
|
||||
|
||||
### Compute the min of a specific column
|
||||
|
||||
```js
|
||||
import "sampledata"
|
||||
import "contrib/jsternberg/aggregate"
|
||||
|
||||
sampledata.float()
|
||||
|> aggregate.table(columns: {"min_bottom_degrees": aggregate.min(column: "_value")})
|
||||
|
||||
```
|
||||
|
||||
{{< expand-wrapper >}}
|
||||
{{% expand "View example input and ouput" %}}
|
||||
|
||||
#### Input data
|
||||
|
||||
| *tag | min_bottom_degrees |
|
||||
| ---- | ------------------- |
|
||||
| t1 | -2.18 |
|
||||
|
||||
| *tag | min_bottom_degrees |
|
||||
| ---- | ------------------- |
|
||||
| t2 | -3.75 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | ------- |
|
||||
| 2021-01-01T00:00:00Z | t1 | -2.18 |
|
||||
| 2021-01-01T00:00:10Z | t1 | 10.92 |
|
||||
| 2021-01-01T00:00:20Z | t1 | 7.35 |
|
||||
| 2021-01-01T00:00:30Z | t1 | 17.53 |
|
||||
| 2021-01-01T00:00:40Z | t1 | 15.23 |
|
||||
| 2021-01-01T00:00:50Z | t1 | 4.43 |
|
||||
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | ------- |
|
||||
| 2021-01-01T00:00:00Z | t2 | 19.85 |
|
||||
| 2021-01-01T00:00:10Z | t2 | 4.97 |
|
||||
| 2021-01-01T00:00:20Z | t2 | -3.75 |
|
||||
| 2021-01-01T00:00:30Z | t2 | 19.77 |
|
||||
| 2021-01-01T00:00:40Z | t2 | 13.86 |
|
||||
| 2021-01-01T00:00:50Z | t2 | 1.86 |
|
||||
|
||||
{{% /expand %}}
|
||||
{{< /expand-wrapper >}}
|
||||
|
|
@ -1,84 +0,0 @@
|
|||
---
|
||||
title: aggregate.window() function
|
||||
description: >
|
||||
`aggregate.window()` aggregates columns and create tables by
|
||||
organizing incoming points into windows.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: aggregate.window
|
||||
parent: contrib/jsternberg/aggregate
|
||||
identifier: contrib/jsternberg/aggregate/window
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/aggregate/aggregate.flux#L71-L81
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`aggregate.window()` aggregates columns and create tables by
|
||||
organizing incoming points into windows.
|
||||
|
||||
Each table will have two additional columns: start and stop.
|
||||
These are the start and stop times for each interval.
|
||||
It is not possible to use start or stop as destination column
|
||||
names with this function. The start and stop columns are not
|
||||
added to the group key.
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(
|
||||
<-tables: stream[B],
|
||||
columns: A,
|
||||
every: duration,
|
||||
?period: duration,
|
||||
?time: string,
|
||||
) => stream[C] where A: Record, B: Record, C: Record
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### tables
|
||||
|
||||
Input data. Default is piped-forward data (`<-`).
|
||||
|
||||
|
||||
|
||||
### columns
|
||||
({{< req >}})
|
||||
Columns to aggregate and which aggregate method to use. See `aggregate.table()` for details.
|
||||
|
||||
|
||||
|
||||
### every
|
||||
({{< req >}})
|
||||
Duration between the start of each interval.
|
||||
|
||||
|
||||
|
||||
### time
|
||||
|
||||
Column name for the time input. Defaults to `_time` or `time` (whichever is earlier in the list of columns).
|
||||
|
||||
|
||||
|
||||
### period
|
||||
|
||||
Length of the interval. Defaults to the `every` duration.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,48 +0,0 @@
|
|||
---
|
||||
title: math.max() function
|
||||
description: >
|
||||
`math.max()` returns the maximum value within the array.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: math.max
|
||||
parent: contrib/jsternberg/math
|
||||
identifier: contrib/jsternberg/math/max
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/math/math.flux#L36-L40
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`math.max()` returns the maximum value within the array.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(values: [A]) => A where A: Numeric
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### values
|
||||
({{< req >}})
|
||||
Array of values.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,48 +0,0 @@
|
|||
---
|
||||
title: math.maxIndex() function
|
||||
description: >
|
||||
`math.maxIndex()` returns the index of the maximum value within the array.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: math.maxIndex
|
||||
parent: contrib/jsternberg/math
|
||||
identifier: contrib/jsternberg/math/maxIndex
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/math/math.flux#L30-L30
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`math.maxIndex()` returns the index of the maximum value within the array.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(values: [A]) => int where A: Numeric
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### values
|
||||
({{< req >}})
|
||||
Array of values.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,48 +0,0 @@
|
|||
---
|
||||
title: math.minIndex() function
|
||||
description: >
|
||||
`math.minIndex()` returns the index of the minimum value within the array.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: math.minIndex
|
||||
parent: contrib/jsternberg/math
|
||||
identifier: contrib/jsternberg/math/minIndex
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/math/math.flux#L14-L14
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`math.minIndex()` returns the index of the minimum value within the array.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(values: [A]) => int where A: Numeric
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### values
|
||||
({{< req >}})
|
||||
Array of values.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,48 +0,0 @@
|
|||
---
|
||||
title: math.sum() function
|
||||
description: >
|
||||
`math.sum()` returns the sum of all values within the array.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: math.sum
|
||||
parent: contrib/jsternberg/math
|
||||
identifier: contrib/jsternberg/math/sum
|
||||
weight: 301
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
||||
IMPORTANT: This page was generated from comments in the Flux source code. Any
|
||||
edits made directly to this page will be overwritten the next time the
|
||||
documentation is generated.
|
||||
|
||||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/math/math.flux#L46-L46
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`math.sum()` returns the sum of all values within the array.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(values: [A]) => A where A: Numeric
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### values
|
||||
({{< req >}})
|
||||
Array of values.
|
||||
|
||||
|
||||
|
||||
|
|
@ -1,16 +1,16 @@
|
|||
---
|
||||
title: math package
|
||||
title: dynamic package
|
||||
description: >
|
||||
The `math` package provides implementations of aggregate functions.
|
||||
The `dynamic` package provides tools for working with values of unknown types.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: math
|
||||
parent: contrib/jsternberg
|
||||
identifier: contrib/jsternberg/math
|
||||
weight: 31
|
||||
name: dynamic
|
||||
parent: experimental
|
||||
identifier: experimental/dynamic
|
||||
weight: 21
|
||||
cascade:
|
||||
|
||||
introduced: 0.77.0
|
||||
introduced: 0.185.0
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
|
@ -22,18 +22,18 @@ documentation is generated.
|
|||
To make updates to this documentation, update the comments above the package
|
||||
declaration in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/math/math.flux
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/experimental/dynamic/dynamic.flux
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
The `math` package provides implementations of aggregate functions.
|
||||
Import the `contrib/jsternberg/math` package:
|
||||
The `dynamic` package provides tools for working with values of unknown types.
|
||||
Import the `experimental/dynamic` package:
|
||||
|
||||
```js
|
||||
import "contrib/jsternberg/math"
|
||||
import "experimental/dynamic"
|
||||
```
|
||||
|
||||
|
||||
|
|
@ -1,13 +1,14 @@
|
|||
---
|
||||
title: math.min() function
|
||||
title: dynamic.dynamic() function
|
||||
description: >
|
||||
`math.min()` returns the minimum value within the array.
|
||||
`dynamic.dynamic()` wraps a value so it can be used as a `dynamic` value.
|
||||
menu:
|
||||
flux_0_x_ref:
|
||||
name: math.min
|
||||
parent: contrib/jsternberg/math
|
||||
identifier: contrib/jsternberg/math/min
|
||||
weight: 301
|
||||
name: dynamic.dynamic
|
||||
parent: experimental/dynamic
|
||||
identifier: experimental/dynamic/dynamic
|
||||
weight: 201
|
||||
flux/v0.x/tags: [type-conversions]
|
||||
---
|
||||
|
||||
<!------------------------------------------------------------------------------
|
||||
|
|
@ -19,30 +20,30 @@ documentation is generated.
|
|||
To make updates to this documentation, update the function comments above the
|
||||
function definition in the Flux source code:
|
||||
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/contrib/jsternberg/math/math.flux#L20-L24
|
||||
https://github.com/influxdata/flux/blob/master/stdlib/experimental/dynamic/dynamic.flux#L16-L16
|
||||
|
||||
Contributing to Flux: https://github.com/influxdata/flux#contributing
|
||||
Fluxdoc syntax: https://github.com/influxdata/flux/blob/master/docs/fluxdoc.md
|
||||
|
||||
------------------------------------------------------------------------------->
|
||||
|
||||
`math.min()` returns the minimum value within the array.
|
||||
`dynamic.dynamic()` wraps a value so it can be used as a `dynamic` value.
|
||||
|
||||
|
||||
|
||||
##### Function type signature
|
||||
|
||||
```js
|
||||
(values: [A]) => A where A: Numeric
|
||||
(v: A) => dynamic
|
||||
```
|
||||
|
||||
{{% caption %}}For more information, see [Function type signatures](/flux/v0.x/function-type-signatures/).{{% /caption %}}
|
||||
|
||||
## Parameters
|
||||
|
||||
### values
|
||||
### v
|
||||
({{< req >}})
|
||||
Array of values.
|
||||
Value to wrap as dynamic.
|
||||
|
||||
|
||||
|
||||
|
|
@ -78,8 +78,8 @@ requests.peek(response: requests.get(url: "https://api.agify.io", params: ["name
|
|||
|
||||
#### Output data
|
||||
|
||||
| body | duration | headers | statusCode |
|
||||
| ----------------------------------------- | --------- | ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | ----------- |
|
||||
| body | duration | headers | statusCode |
|
||||
| ----------------------------------------- | --------- | ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------ | ----------- |
|
||||
| {"age":48,"count":25082,"name":"natalie"} | 100000000 | [
|
||||
Access-Control-Allow-Credentials: true,
|
||||
Access-Control-Allow-Origin: *,
|
||||
|
|
@ -88,12 +88,12 @@ requests.peek(response: requests.get(url: "https://api.agify.io", params: ["name
|
|||
Connection: keep-alive,
|
||||
Content-Length: 41,
|
||||
Content-Type: application/json; charset=utf-8,
|
||||
Date: Wed, 21 Sep 2022 10:08:38 GMT,
|
||||
Date: Mon, 03 Oct 2022 21:20:22 GMT,
|
||||
Server: nginx/1.16.1,
|
||||
X-Rate-Limit-Limit: 1000,
|
||||
X-Rate-Limit-Remaining: 998,
|
||||
X-Rate-Limit-Reset: 49882,
|
||||
X-Request-Id: FxbYSI-0Y_v6ACsAkbHS
|
||||
X-Rate-Limit-Reset: 9578,
|
||||
X-Request-Id: Fxqr53E2jz6yFf4AFNpR
|
||||
] | 200 |
|
||||
|
||||
{{% /expand %}}
|
||||
|
|
|
|||
|
|
@ -107,44 +107,44 @@ data
|
|||
|
||||
| _time | _value |
|
||||
| -------------------- | ------------------- |
|
||||
| 2022-09-21T10:05:50Z | 10.56555566168836 |
|
||||
| 2022-09-21T10:06:00Z | -29.76098586714259 |
|
||||
| 2022-09-21T10:06:10Z | -67.50435038579738 |
|
||||
| 2022-09-21T10:06:20Z | -16.758669047964453 |
|
||||
| 2022-09-21T10:06:30Z | -47.25865245658065 |
|
||||
| 2022-09-21T10:06:40Z | 66.16082461651365 |
|
||||
| 2022-09-21T10:06:50Z | -0.9179216017921821 |
|
||||
| 2022-09-21T10:07:00Z | -56.89169240573004 |
|
||||
| 2022-09-21T10:07:10Z | 11.358605472976624 |
|
||||
| 2022-09-21T10:07:20Z | 28.71147881415803 |
|
||||
| 2022-09-21T10:07:30Z | -30.928830759588756 |
|
||||
| 2022-09-21T10:07:40Z | -22.411848631056067 |
|
||||
| 2022-09-21T10:07:50Z | 17.05503606764129 |
|
||||
| 2022-09-21T10:08:00Z | 9.834382683760559 |
|
||||
| 2022-09-21T10:08:10Z | -12.62058579127679 |
|
||||
| 2022-09-21T10:08:20Z | -44.44668391211515 |
|
||||
| 2022-10-03T21:17:40Z | 10.56555566168836 |
|
||||
| 2022-10-03T21:17:50Z | -29.76098586714259 |
|
||||
| 2022-10-03T21:18:00Z | -67.50435038579738 |
|
||||
| 2022-10-03T21:18:10Z | -16.758669047964453 |
|
||||
| 2022-10-03T21:18:20Z | -47.25865245658065 |
|
||||
| 2022-10-03T21:18:30Z | 66.16082461651365 |
|
||||
| 2022-10-03T21:18:40Z | -0.9179216017921821 |
|
||||
| 2022-10-03T21:18:50Z | -56.89169240573004 |
|
||||
| 2022-10-03T21:19:00Z | 11.358605472976624 |
|
||||
| 2022-10-03T21:19:10Z | 28.71147881415803 |
|
||||
| 2022-10-03T21:19:20Z | -30.928830759588756 |
|
||||
| 2022-10-03T21:19:30Z | -22.411848631056067 |
|
||||
| 2022-10-03T21:19:40Z | 17.05503606764129 |
|
||||
| 2022-10-03T21:19:50Z | 9.834382683760559 |
|
||||
| 2022-10-03T21:20:00Z | -12.62058579127679 |
|
||||
| 2022-10-03T21:20:10Z | -44.44668391211515 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
||||
| _time | _value |
|
||||
| -------------------- | ------------------- |
|
||||
| 2022-09-21T10:05:50Z | 10.56555566168836 |
|
||||
| 2022-09-21T10:06:00Z | -29.76098586714259 |
|
||||
| 2022-09-21T10:06:10Z | -67.50435038579738 |
|
||||
| 2022-09-21T10:06:20Z | -16.758669047964453 |
|
||||
| 2022-09-21T10:06:30Z | -47.25865245658065 |
|
||||
| 2022-09-21T10:06:40Z | 66.16082461651365 |
|
||||
| 2022-09-21T10:06:50Z | -0.9179216017921821 |
|
||||
| 2022-09-21T10:07:00Z | -56.89169240573004 |
|
||||
| 2022-09-21T10:07:10Z | 11.358605472976624 |
|
||||
| 2022-09-21T10:07:20Z | 28.71147881415803 |
|
||||
| 2022-09-21T10:07:30Z | -30.928830759588756 |
|
||||
| 2022-09-21T10:07:40Z | -22.411848631056067 |
|
||||
| 2022-09-21T10:07:50Z | 17.05503606764129 |
|
||||
| 2022-09-21T10:08:00Z | 9.834382683760559 |
|
||||
| 2022-09-21T10:08:10Z | -12.62058579127679 |
|
||||
| 2022-09-21T10:08:20Z | -44.44668391211515 |
|
||||
| 2022-10-03T21:17:40Z | 10.56555566168836 |
|
||||
| 2022-10-03T21:17:50Z | -29.76098586714259 |
|
||||
| 2022-10-03T21:18:00Z | -67.50435038579738 |
|
||||
| 2022-10-03T21:18:10Z | -16.758669047964453 |
|
||||
| 2022-10-03T21:18:20Z | -47.25865245658065 |
|
||||
| 2022-10-03T21:18:30Z | 66.16082461651365 |
|
||||
| 2022-10-03T21:18:40Z | -0.9179216017921821 |
|
||||
| 2022-10-03T21:18:50Z | -56.89169240573004 |
|
||||
| 2022-10-03T21:19:00Z | 11.358605472976624 |
|
||||
| 2022-10-03T21:19:10Z | 28.71147881415803 |
|
||||
| 2022-10-03T21:19:20Z | -30.928830759588756 |
|
||||
| 2022-10-03T21:19:30Z | -22.411848631056067 |
|
||||
| 2022-10-03T21:19:40Z | 17.05503606764129 |
|
||||
| 2022-10-03T21:19:50Z | 9.834382683760559 |
|
||||
| 2022-10-03T21:20:00Z | -12.62058579127679 |
|
||||
| 2022-10-03T21:20:10Z | -44.44668391211515 |
|
||||
|
||||
{{% /expand %}}
|
||||
{{< /expand-wrapper >}}
|
||||
|
|
@ -166,43 +166,43 @@ data
|
|||
|
||||
| _time | _value |
|
||||
| -------------------- | ------------------- |
|
||||
| 2022-09-21T10:05:50Z | 10.56555566168836 |
|
||||
| 2022-09-21T10:06:00Z | -29.76098586714259 |
|
||||
| 2022-09-21T10:06:10Z | -67.50435038579738 |
|
||||
| 2022-09-21T10:06:20Z | -16.758669047964453 |
|
||||
| 2022-09-21T10:06:30Z | -47.25865245658065 |
|
||||
| 2022-09-21T10:06:40Z | 66.16082461651365 |
|
||||
| 2022-09-21T10:06:50Z | -0.9179216017921821 |
|
||||
| 2022-09-21T10:07:00Z | -56.89169240573004 |
|
||||
| 2022-09-21T10:07:10Z | 11.358605472976624 |
|
||||
| 2022-09-21T10:07:20Z | 28.71147881415803 |
|
||||
| 2022-09-21T10:07:30Z | -30.928830759588756 |
|
||||
| 2022-09-21T10:07:40Z | -22.411848631056067 |
|
||||
| 2022-09-21T10:07:50Z | 17.05503606764129 |
|
||||
| 2022-09-21T10:08:00Z | 9.834382683760559 |
|
||||
| 2022-09-21T10:08:10Z | -12.62058579127679 |
|
||||
| 2022-09-21T10:08:20Z | -44.44668391211515 |
|
||||
| 2022-10-03T21:17:40Z | 10.56555566168836 |
|
||||
| 2022-10-03T21:17:50Z | -29.76098586714259 |
|
||||
| 2022-10-03T21:18:00Z | -67.50435038579738 |
|
||||
| 2022-10-03T21:18:10Z | -16.758669047964453 |
|
||||
| 2022-10-03T21:18:20Z | -47.25865245658065 |
|
||||
| 2022-10-03T21:18:30Z | 66.16082461651365 |
|
||||
| 2022-10-03T21:18:40Z | -0.9179216017921821 |
|
||||
| 2022-10-03T21:18:50Z | -56.89169240573004 |
|
||||
| 2022-10-03T21:19:00Z | 11.358605472976624 |
|
||||
| 2022-10-03T21:19:10Z | 28.71147881415803 |
|
||||
| 2022-10-03T21:19:20Z | -30.928830759588756 |
|
||||
| 2022-10-03T21:19:30Z | -22.411848631056067 |
|
||||
| 2022-10-03T21:19:40Z | 17.05503606764129 |
|
||||
| 2022-10-03T21:19:50Z | 9.834382683760559 |
|
||||
| 2022-10-03T21:20:00Z | -12.62058579127679 |
|
||||
| 2022-10-03T21:20:10Z | -44.44668391211515 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
||||
| _time | _value |
|
||||
| -------------------- | ------------------- |
|
||||
| 2022-09-21T10:05:50Z | 10.56555566168836 |
|
||||
| 2022-09-21T10:06:10Z | -67.50435038579738 |
|
||||
| 2022-09-21T10:06:20Z | -16.758669047964453 |
|
||||
| 2022-09-21T10:06:30Z | -47.25865245658065 |
|
||||
| 2022-09-21T10:06:40Z | 66.16082461651365 |
|
||||
| 2022-09-21T10:06:50Z | -0.9179216017921821 |
|
||||
| 2022-09-21T10:07:00Z | -56.89169240573004 |
|
||||
| 2022-09-21T10:07:10Z | 11.358605472976624 |
|
||||
| 2022-09-21T10:07:20Z | 28.71147881415803 |
|
||||
| 2022-09-21T10:07:30Z | -30.928830759588756 |
|
||||
| 2022-09-21T10:07:40Z | -22.411848631056067 |
|
||||
| 2022-09-21T10:07:50Z | 17.05503606764129 |
|
||||
| 2022-09-21T10:08:00Z | 9.834382683760559 |
|
||||
| 2022-09-21T10:08:10Z | -12.62058579127679 |
|
||||
| 2022-09-21T10:08:20Z | -44.44668391211515 |
|
||||
| 2022-10-03T21:17:40Z | 10.56555566168836 |
|
||||
| 2022-10-03T21:18:00Z | -67.50435038579738 |
|
||||
| 2022-10-03T21:18:10Z | -16.758669047964453 |
|
||||
| 2022-10-03T21:18:20Z | -47.25865245658065 |
|
||||
| 2022-10-03T21:18:30Z | 66.16082461651365 |
|
||||
| 2022-10-03T21:18:40Z | -0.9179216017921821 |
|
||||
| 2022-10-03T21:18:50Z | -56.89169240573004 |
|
||||
| 2022-10-03T21:19:00Z | 11.358605472976624 |
|
||||
| 2022-10-03T21:19:10Z | 28.71147881415803 |
|
||||
| 2022-10-03T21:19:20Z | -30.928830759588756 |
|
||||
| 2022-10-03T21:19:30Z | -22.411848631056067 |
|
||||
| 2022-10-03T21:19:40Z | 17.05503606764129 |
|
||||
| 2022-10-03T21:19:50Z | 9.834382683760559 |
|
||||
| 2022-10-03T21:20:00Z | -12.62058579127679 |
|
||||
| 2022-10-03T21:20:10Z | -44.44668391211515 |
|
||||
|
||||
{{% /expand %}}
|
||||
{{< /expand-wrapper >}}
|
||||
|
|
@ -224,42 +224,42 @@ data
|
|||
|
||||
| _time | _value |
|
||||
| -------------------- | ------------------- |
|
||||
| 2022-09-21T10:05:50Z | 10.56555566168836 |
|
||||
| 2022-09-21T10:06:00Z | -29.76098586714259 |
|
||||
| 2022-09-21T10:06:10Z | -67.50435038579738 |
|
||||
| 2022-09-21T10:06:20Z | -16.758669047964453 |
|
||||
| 2022-09-21T10:06:30Z | -47.25865245658065 |
|
||||
| 2022-09-21T10:06:40Z | 66.16082461651365 |
|
||||
| 2022-09-21T10:06:50Z | -0.9179216017921821 |
|
||||
| 2022-09-21T10:07:00Z | -56.89169240573004 |
|
||||
| 2022-09-21T10:07:10Z | 11.358605472976624 |
|
||||
| 2022-09-21T10:07:20Z | 28.71147881415803 |
|
||||
| 2022-09-21T10:07:30Z | -30.928830759588756 |
|
||||
| 2022-09-21T10:07:40Z | -22.411848631056067 |
|
||||
| 2022-09-21T10:07:50Z | 17.05503606764129 |
|
||||
| 2022-09-21T10:08:00Z | 9.834382683760559 |
|
||||
| 2022-09-21T10:08:10Z | -12.62058579127679 |
|
||||
| 2022-09-21T10:08:20Z | -44.44668391211515 |
|
||||
| 2022-10-03T21:17:40Z | 10.56555566168836 |
|
||||
| 2022-10-03T21:17:50Z | -29.76098586714259 |
|
||||
| 2022-10-03T21:18:00Z | -67.50435038579738 |
|
||||
| 2022-10-03T21:18:10Z | -16.758669047964453 |
|
||||
| 2022-10-03T21:18:20Z | -47.25865245658065 |
|
||||
| 2022-10-03T21:18:30Z | 66.16082461651365 |
|
||||
| 2022-10-03T21:18:40Z | -0.9179216017921821 |
|
||||
| 2022-10-03T21:18:50Z | -56.89169240573004 |
|
||||
| 2022-10-03T21:19:00Z | 11.358605472976624 |
|
||||
| 2022-10-03T21:19:10Z | 28.71147881415803 |
|
||||
| 2022-10-03T21:19:20Z | -30.928830759588756 |
|
||||
| 2022-10-03T21:19:30Z | -22.411848631056067 |
|
||||
| 2022-10-03T21:19:40Z | 17.05503606764129 |
|
||||
| 2022-10-03T21:19:50Z | 9.834382683760559 |
|
||||
| 2022-10-03T21:20:00Z | -12.62058579127679 |
|
||||
| 2022-10-03T21:20:10Z | -44.44668391211515 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
||||
| _time | _value |
|
||||
| -------------------- | ------------------- |
|
||||
| 2022-09-21T10:05:50Z | 10.56555566168836 |
|
||||
| 2022-09-21T10:06:10Z | -67.50435038579738 |
|
||||
| 2022-09-21T10:06:20Z | -16.758669047964453 |
|
||||
| 2022-09-21T10:06:30Z | -47.25865245658065 |
|
||||
| 2022-09-21T10:06:40Z | 66.16082461651365 |
|
||||
| 2022-09-21T10:06:50Z | -0.9179216017921821 |
|
||||
| 2022-09-21T10:07:00Z | -56.89169240573004 |
|
||||
| 2022-09-21T10:07:10Z | 11.358605472976624 |
|
||||
| 2022-09-21T10:07:20Z | 28.71147881415803 |
|
||||
| 2022-09-21T10:07:30Z | -30.928830759588756 |
|
||||
| 2022-09-21T10:07:40Z | -22.411848631056067 |
|
||||
| 2022-09-21T10:07:50Z | 17.05503606764129 |
|
||||
| 2022-09-21T10:08:00Z | 9.834382683760559 |
|
||||
| 2022-09-21T10:08:20Z | -44.44668391211515 |
|
||||
| 2022-10-03T21:17:40Z | 10.56555566168836 |
|
||||
| 2022-10-03T21:18:00Z | -67.50435038579738 |
|
||||
| 2022-10-03T21:18:10Z | -16.758669047964453 |
|
||||
| 2022-10-03T21:18:20Z | -47.25865245658065 |
|
||||
| 2022-10-03T21:18:30Z | 66.16082461651365 |
|
||||
| 2022-10-03T21:18:40Z | -0.9179216017921821 |
|
||||
| 2022-10-03T21:18:50Z | -56.89169240573004 |
|
||||
| 2022-10-03T21:19:00Z | 11.358605472976624 |
|
||||
| 2022-10-03T21:19:10Z | 28.71147881415803 |
|
||||
| 2022-10-03T21:19:20Z | -30.928830759588756 |
|
||||
| 2022-10-03T21:19:30Z | -22.411848631056067 |
|
||||
| 2022-10-03T21:19:40Z | 17.05503606764129 |
|
||||
| 2022-10-03T21:19:50Z | 9.834382683760559 |
|
||||
| 2022-10-03T21:20:10Z | -44.44668391211515 |
|
||||
|
||||
{{% /expand %}}
|
||||
{{< /expand-wrapper >}}
|
||||
|
|
|
|||
|
|
@ -67,7 +67,7 @@ Default value to return if the specified key does not exist in the record.
|
|||
|
||||
## Examples
|
||||
|
||||
### Dynamically return a value from a recordd
|
||||
### Dynamically return a value from a record
|
||||
|
||||
```js
|
||||
import "experimental/record"
|
||||
|
|
|
|||
|
|
@ -73,8 +73,8 @@ requests.peek(response: requests.get(url: "https://api.agify.io", params: ["name
|
|||
|
||||
#### Output data
|
||||
|
||||
| body | duration | headers | statusCode |
|
||||
| ----------------------------------------- | --------- | ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | ----------- |
|
||||
| body | duration | headers | statusCode |
|
||||
| ----------------------------------------- | --------- | ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------ | ----------- |
|
||||
| {"age":48,"count":25082,"name":"natalie"} | 100000000 | [
|
||||
Access-Control-Allow-Credentials: true,
|
||||
Access-Control-Allow-Origin: *,
|
||||
|
|
@ -83,12 +83,12 @@ requests.peek(response: requests.get(url: "https://api.agify.io", params: ["name
|
|||
Connection: keep-alive,
|
||||
Content-Length: 41,
|
||||
Content-Type: application/json; charset=utf-8,
|
||||
Date: Wed, 21 Sep 2022 10:08:39 GMT,
|
||||
Date: Mon, 03 Oct 2022 21:20:24 GMT,
|
||||
Server: nginx/1.16.1,
|
||||
X-Rate-Limit-Limit: 1000,
|
||||
X-Rate-Limit-Remaining: 996,
|
||||
X-Rate-Limit-Reset: 49881,
|
||||
X-Request-Id: FxbYSObVA-veXYEAkbRi
|
||||
X-Rate-Limit-Reset: 9576,
|
||||
X-Request-Id: Fxqr57xYrpSg2VIAFNtx
|
||||
] | 200 |
|
||||
|
||||
{{% /expand %}}
|
||||
|
|
|
|||
|
|
@ -189,12 +189,12 @@ requests.peek(response: response)
|
|||
Cache-Control: max-age=604800,
|
||||
Content-Length: 1256,
|
||||
Content-Type: text/html; charset=UTF-8,
|
||||
Date: Wed, 21 Sep 2022 10:08:40 GMT,
|
||||
Date: Mon, 03 Oct 2022 21:20:24 GMT,
|
||||
Etag: "3147526947",
|
||||
Expires: Wed, 28 Sep 2022 10:08:40 GMT,
|
||||
Expires: Mon, 10 Oct 2022 21:20:24 GMT,
|
||||
Last-Modified: Thu, 17 Oct 2019 07:18:26 GMT,
|
||||
Server: EOS (vny/0453)
|
||||
] | 147139602 |
|
||||
Server: EOS (vny/0452)
|
||||
] | 97985198 |
|
||||
|
||||
{{% /expand %}}
|
||||
{{< /expand-wrapper >}}
|
||||
|
|
|
|||
|
|
@ -79,23 +79,23 @@ data
|
|||
|
||||
#### Input data
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | --------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | -0.021800000000000003 | t1 |
|
||||
| 2021-01-01T00:00:10Z | 0.1092 | t1 |
|
||||
| 2021-01-01T00:00:20Z | 0.0735 | t1 |
|
||||
| 2021-01-01T00:00:30Z | 0.1753 | t1 |
|
||||
| 2021-01-01T00:00:40Z | 0.15230000000000002 | t1 |
|
||||
| 2021-01-01T00:00:50Z | 0.0443 | t1 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | --------------------- |
|
||||
| 2021-01-01T00:00:00Z | t1 | -0.021800000000000003 |
|
||||
| 2021-01-01T00:00:10Z | t1 | 0.1092 |
|
||||
| 2021-01-01T00:00:20Z | t1 | 0.0735 |
|
||||
| 2021-01-01T00:00:30Z | t1 | 0.1753 |
|
||||
| 2021-01-01T00:00:40Z | t1 | 0.15230000000000002 |
|
||||
| 2021-01-01T00:00:50Z | t1 | 0.0443 |
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | -------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | 0.1985 | t2 |
|
||||
| 2021-01-01T00:00:10Z | 0.0497 | t2 |
|
||||
| 2021-01-01T00:00:20Z | -0.0375 | t2 |
|
||||
| 2021-01-01T00:00:30Z | 0.1977 | t2 |
|
||||
| 2021-01-01T00:00:40Z | 0.1386 | t2 |
|
||||
| 2021-01-01T00:00:50Z | 0.018600000000000002 | t2 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | -------------------- |
|
||||
| 2021-01-01T00:00:00Z | t2 | 0.1985 |
|
||||
| 2021-01-01T00:00:10Z | t2 | 0.0497 |
|
||||
| 2021-01-01T00:00:20Z | t2 | -0.0375 |
|
||||
| 2021-01-01T00:00:30Z | t2 | 0.1977 |
|
||||
| 2021-01-01T00:00:40Z | t2 | 0.1386 |
|
||||
| 2021-01-01T00:00:50Z | t2 | 0.018600000000000002 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
|
|
|||
|
|
@ -77,23 +77,23 @@ data
|
|||
|
||||
#### Input data
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | -------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | -0.21800000000000003 | t1 |
|
||||
| 2021-01-01T00:00:10Z | 1.092 | t1 |
|
||||
| 2021-01-01T00:00:20Z | 0.735 | t1 |
|
||||
| 2021-01-01T00:00:30Z | 1.7530000000000001 | t1 |
|
||||
| 2021-01-01T00:00:40Z | 1.5230000000000001 | t1 |
|
||||
| 2021-01-01T00:00:50Z | 0.443 | t1 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | -------------------- |
|
||||
| 2021-01-01T00:00:00Z | t1 | -0.21800000000000003 |
|
||||
| 2021-01-01T00:00:10Z | t1 | 1.092 |
|
||||
| 2021-01-01T00:00:20Z | t1 | 0.735 |
|
||||
| 2021-01-01T00:00:30Z | t1 | 1.7530000000000001 |
|
||||
| 2021-01-01T00:00:40Z | t1 | 1.5230000000000001 |
|
||||
| 2021-01-01T00:00:50Z | t1 | 0.443 |
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | ------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | 1.9850000000000003 | t2 |
|
||||
| 2021-01-01T00:00:10Z | 0.497 | t2 |
|
||||
| 2021-01-01T00:00:20Z | -0.375 | t2 |
|
||||
| 2021-01-01T00:00:30Z | 1.977 | t2 |
|
||||
| 2021-01-01T00:00:40Z | 1.3860000000000001 | t2 |
|
||||
| 2021-01-01T00:00:50Z | 0.18600000000000003 | t2 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | ------------------- |
|
||||
| 2021-01-01T00:00:00Z | t2 | 1.9850000000000003 |
|
||||
| 2021-01-01T00:00:10Z | t2 | 0.497 |
|
||||
| 2021-01-01T00:00:20Z | t2 | -0.375 |
|
||||
| 2021-01-01T00:00:30Z | t2 | 1.977 |
|
||||
| 2021-01-01T00:00:40Z | t2 | 1.3860000000000001 |
|
||||
| 2021-01-01T00:00:50Z | t2 | 0.18600000000000003 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
|
|
|||
|
|
@ -78,23 +78,23 @@ data
|
|||
|
||||
#### Input data
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | --------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | -0.021800000000000003 | t1 |
|
||||
| 2021-01-01T00:00:10Z | 0.1092 | t1 |
|
||||
| 2021-01-01T00:00:20Z | 0.0735 | t1 |
|
||||
| 2021-01-01T00:00:30Z | 0.1753 | t1 |
|
||||
| 2021-01-01T00:00:40Z | 0.15230000000000002 | t1 |
|
||||
| 2021-01-01T00:00:50Z | 0.0443 | t1 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | --------------------- |
|
||||
| 2021-01-01T00:00:00Z | t1 | -0.021800000000000003 |
|
||||
| 2021-01-01T00:00:10Z | t1 | 0.1092 |
|
||||
| 2021-01-01T00:00:20Z | t1 | 0.0735 |
|
||||
| 2021-01-01T00:00:30Z | t1 | 0.1753 |
|
||||
| 2021-01-01T00:00:40Z | t1 | 0.15230000000000002 |
|
||||
| 2021-01-01T00:00:50Z | t1 | 0.0443 |
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | -------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | 0.1985 | t2 |
|
||||
| 2021-01-01T00:00:10Z | 0.0497 | t2 |
|
||||
| 2021-01-01T00:00:20Z | -0.0375 | t2 |
|
||||
| 2021-01-01T00:00:30Z | 0.1977 | t2 |
|
||||
| 2021-01-01T00:00:40Z | 0.1386 | t2 |
|
||||
| 2021-01-01T00:00:50Z | 0.018600000000000002 | t2 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | -------------------- |
|
||||
| 2021-01-01T00:00:00Z | t2 | 0.1985 |
|
||||
| 2021-01-01T00:00:10Z | t2 | 0.0497 |
|
||||
| 2021-01-01T00:00:20Z | t2 | -0.0375 |
|
||||
| 2021-01-01T00:00:30Z | t2 | 0.1977 |
|
||||
| 2021-01-01T00:00:40Z | t2 | 0.1386 |
|
||||
| 2021-01-01T00:00:50Z | t2 | 0.018600000000000002 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
|
|
|||
|
|
@ -79,23 +79,23 @@ data
|
|||
|
||||
#### Input data
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | --------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | -0.021800000000000003 | t1 |
|
||||
| 2021-01-01T00:00:10Z | 0.1092 | t1 |
|
||||
| 2021-01-01T00:00:20Z | 0.0735 | t1 |
|
||||
| 2021-01-01T00:00:30Z | 0.1753 | t1 |
|
||||
| 2021-01-01T00:00:40Z | 0.15230000000000002 | t1 |
|
||||
| 2021-01-01T00:00:50Z | 0.0443 | t1 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | --------------------- |
|
||||
| 2021-01-01T00:00:00Z | t1 | -0.021800000000000003 |
|
||||
| 2021-01-01T00:00:10Z | t1 | 0.1092 |
|
||||
| 2021-01-01T00:00:20Z | t1 | 0.0735 |
|
||||
| 2021-01-01T00:00:30Z | t1 | 0.1753 |
|
||||
| 2021-01-01T00:00:40Z | t1 | 0.15230000000000002 |
|
||||
| 2021-01-01T00:00:50Z | t1 | 0.0443 |
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | -------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | 0.1985 | t2 |
|
||||
| 2021-01-01T00:00:10Z | 0.0497 | t2 |
|
||||
| 2021-01-01T00:00:20Z | -0.0375 | t2 |
|
||||
| 2021-01-01T00:00:30Z | 0.1977 | t2 |
|
||||
| 2021-01-01T00:00:40Z | 0.1386 | t2 |
|
||||
| 2021-01-01T00:00:50Z | 0.018600000000000002 | t2 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | -------------------- |
|
||||
| 2021-01-01T00:00:00Z | t2 | 0.1985 |
|
||||
| 2021-01-01T00:00:10Z | t2 | 0.0497 |
|
||||
| 2021-01-01T00:00:20Z | t2 | -0.0375 |
|
||||
| 2021-01-01T00:00:30Z | t2 | 0.1977 |
|
||||
| 2021-01-01T00:00:40Z | t2 | 0.1386 |
|
||||
| 2021-01-01T00:00:50Z | t2 | 0.018600000000000002 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
|
|
|||
|
|
@ -80,23 +80,23 @@ data
|
|||
|
||||
#### Input data
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | --------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | -0.021800000000000003 | t1 |
|
||||
| 2021-01-01T00:00:10Z | 0.1092 | t1 |
|
||||
| 2021-01-01T00:00:20Z | 0.0735 | t1 |
|
||||
| 2021-01-01T00:00:30Z | 0.1753 | t1 |
|
||||
| 2021-01-01T00:00:40Z | 0.15230000000000002 | t1 |
|
||||
| 2021-01-01T00:00:50Z | 0.0443 | t1 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | --------------------- |
|
||||
| 2021-01-01T00:00:00Z | t1 | -0.021800000000000003 |
|
||||
| 2021-01-01T00:00:10Z | t1 | 0.1092 |
|
||||
| 2021-01-01T00:00:20Z | t1 | 0.0735 |
|
||||
| 2021-01-01T00:00:30Z | t1 | 0.1753 |
|
||||
| 2021-01-01T00:00:40Z | t1 | 0.15230000000000002 |
|
||||
| 2021-01-01T00:00:50Z | t1 | 0.0443 |
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | -------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | 0.1985 | t2 |
|
||||
| 2021-01-01T00:00:10Z | 0.0497 | t2 |
|
||||
| 2021-01-01T00:00:20Z | -0.0375 | t2 |
|
||||
| 2021-01-01T00:00:30Z | 0.1977 | t2 |
|
||||
| 2021-01-01T00:00:40Z | 0.1386 | t2 |
|
||||
| 2021-01-01T00:00:50Z | 0.018600000000000002 | t2 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | -------------------- |
|
||||
| 2021-01-01T00:00:00Z | t2 | 0.1985 |
|
||||
| 2021-01-01T00:00:10Z | t2 | 0.0497 |
|
||||
| 2021-01-01T00:00:20Z | t2 | -0.0375 |
|
||||
| 2021-01-01T00:00:30Z | t2 | 0.1977 |
|
||||
| 2021-01-01T00:00:40Z | t2 | 0.1386 |
|
||||
| 2021-01-01T00:00:50Z | t2 | 0.018600000000000002 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
|
|
|||
|
|
@ -82,23 +82,23 @@ data
|
|||
|
||||
#### Input data
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | --------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | -0.021800000000000003 | t1 |
|
||||
| 2021-01-01T00:00:10Z | 0.1092 | t1 |
|
||||
| 2021-01-01T00:00:20Z | 0.0735 | t1 |
|
||||
| 2021-01-01T00:00:30Z | 0.1753 | t1 |
|
||||
| 2021-01-01T00:00:40Z | 0.15230000000000002 | t1 |
|
||||
| 2021-01-01T00:00:50Z | 0.0443 | t1 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | --------------------- |
|
||||
| 2021-01-01T00:00:00Z | t1 | -0.021800000000000003 |
|
||||
| 2021-01-01T00:00:10Z | t1 | 0.1092 |
|
||||
| 2021-01-01T00:00:20Z | t1 | 0.0735 |
|
||||
| 2021-01-01T00:00:30Z | t1 | 0.1753 |
|
||||
| 2021-01-01T00:00:40Z | t1 | 0.15230000000000002 |
|
||||
| 2021-01-01T00:00:50Z | t1 | 0.0443 |
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | -------------------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | 0.1985 | t2 |
|
||||
| 2021-01-01T00:00:10Z | 0.0497 | t2 |
|
||||
| 2021-01-01T00:00:20Z | -0.0375 | t2 |
|
||||
| 2021-01-01T00:00:30Z | 0.1977 | t2 |
|
||||
| 2021-01-01T00:00:40Z | 0.1386 | t2 |
|
||||
| 2021-01-01T00:00:50Z | 0.018600000000000002 | t2 |
|
||||
| _time | *tag | _value |
|
||||
| -------------------- | ---- | -------------------- |
|
||||
| 2021-01-01T00:00:00Z | t2 | 0.1985 |
|
||||
| 2021-01-01T00:00:10Z | t2 | 0.0497 |
|
||||
| 2021-01-01T00:00:20Z | t2 | -0.0375 |
|
||||
| 2021-01-01T00:00:30Z | t2 | 0.1977 |
|
||||
| 2021-01-01T00:00:40Z | t2 | 0.1386 |
|
||||
| 2021-01-01T00:00:50Z | t2 | 0.018600000000000002 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
|
|
|||
|
|
@ -41,7 +41,7 @@ import statement.
|
|||
inf
|
||||
```
|
||||
|
||||
- **inf** represents an infinte float value.
|
||||
- **inf** represents a floating point value of infinity.
|
||||
|
||||
## Options
|
||||
|
||||
|
|
|
|||
|
|
@ -117,12 +117,12 @@ sampledata.int()
|
|||
| 2021-01-01T00:00:40Z | 13 | t2 |
|
||||
| 2021-01-01T00:00:50Z | 1 | t2 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
||||
| _time | _value | *tag |
|
||||
| ------ | ------- | ---- |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
||||
| _time | _value | *tag |
|
||||
| -------------------- | ------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | 19 | t2 |
|
||||
|
|
|
|||
|
|
@ -91,23 +91,23 @@ data
|
|||
|
||||
#### Input data
|
||||
|
||||
| _time | _value | exampleCol | *tag |
|
||||
| -------------------- | ------- | ----------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | -2 | -2000000000 | t1 |
|
||||
| 2021-01-01T00:00:10Z | 10 | 10000000000 | t1 |
|
||||
| 2021-01-01T00:00:20Z | 7 | 7000000000 | t1 |
|
||||
| 2021-01-01T00:00:30Z | 17 | 17000000000 | t1 |
|
||||
| 2021-01-01T00:00:40Z | 15 | 15000000000 | t1 |
|
||||
| 2021-01-01T00:00:50Z | 4 | 4000000000 | t1 |
|
||||
| _time | _value | *tag | exampleCol |
|
||||
| -------------------- | ------- | ---- | ----------- |
|
||||
| 2021-01-01T00:00:00Z | -2 | t1 | -2000000000 |
|
||||
| 2021-01-01T00:00:10Z | 10 | t1 | 10000000000 |
|
||||
| 2021-01-01T00:00:20Z | 7 | t1 | 7000000000 |
|
||||
| 2021-01-01T00:00:30Z | 17 | t1 | 17000000000 |
|
||||
| 2021-01-01T00:00:40Z | 15 | t1 | 15000000000 |
|
||||
| 2021-01-01T00:00:50Z | 4 | t1 | 4000000000 |
|
||||
|
||||
| _time | _value | exampleCol | *tag |
|
||||
| -------------------- | ------- | ----------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | 19 | 19000000000 | t2 |
|
||||
| 2021-01-01T00:00:10Z | 4 | 4000000000 | t2 |
|
||||
| 2021-01-01T00:00:20Z | -3 | -3000000000 | t2 |
|
||||
| 2021-01-01T00:00:30Z | 19 | 19000000000 | t2 |
|
||||
| 2021-01-01T00:00:40Z | 13 | 13000000000 | t2 |
|
||||
| 2021-01-01T00:00:50Z | 1 | 1000000000 | t2 |
|
||||
| _time | _value | *tag | exampleCol |
|
||||
| -------------------- | ------- | ---- | ----------- |
|
||||
| 2021-01-01T00:00:00Z | 19 | t2 | 19000000000 |
|
||||
| 2021-01-01T00:00:10Z | 4 | t2 | 4000000000 |
|
||||
| 2021-01-01T00:00:20Z | -3 | t2 | -3000000000 |
|
||||
| 2021-01-01T00:00:30Z | 19 | t2 | 19000000000 |
|
||||
| 2021-01-01T00:00:40Z | 13 | t2 | 13000000000 |
|
||||
| 2021-01-01T00:00:50Z | 1 | t2 | 1000000000 |
|
||||
|
||||
|
||||
#### Output data
|
||||
|
|
|
|||
|
|
@ -149,14 +149,14 @@ union(tables: [t1, t2])
|
|||
|
||||
| _time | _value | tag |
|
||||
| -------------------- | ------- | ---- |
|
||||
| 2021-01-01T00:00:00Z | 0 | bar |
|
||||
| 2021-01-02T00:00:00Z | -1 | bar |
|
||||
| 2021-01-03T00:00:00Z | -2 | bar |
|
||||
| 2021-01-04T00:00:00Z | -3 | bar |
|
||||
| 2021-01-01T00:00:00Z | 1 | foo |
|
||||
| 2021-01-02T00:00:00Z | 2 | foo |
|
||||
| 2021-01-03T00:00:00Z | 3 | foo |
|
||||
| 2021-01-04T00:00:00Z | 4 | foo |
|
||||
| 2021-01-01T00:00:00Z | 0 | bar |
|
||||
| 2021-01-02T00:00:00Z | -1 | bar |
|
||||
| 2021-01-03T00:00:00Z | -2 | bar |
|
||||
| 2021-01-04T00:00:00Z | -3 | bar |
|
||||
|
||||
{{% /expand %}}
|
||||
{{< /expand-wrapper >}}
|
||||
|
|
|
|||
|
|
@ -10,8 +10,14 @@ menu:
|
|||
parent: Query with Flux
|
||||
weight: 210
|
||||
related:
|
||||
- /{{< latest "flux" >}}/stdlib/universe/join
|
||||
list_query_example: join
|
||||
- /{{< latest "flux" >}}/join-data/
|
||||
- /{{< latest "flux" >}}/join-data/inner/
|
||||
- /{{< latest "flux" >}}/join-data/left-outer/
|
||||
- /{{< latest "flux" >}}/join-data/right-outer/
|
||||
- /{{< latest "flux" >}}/join-data/full-outer/
|
||||
- /{{< latest "flux" >}}/join-data/time/
|
||||
- /{{< latest "flux" >}}/stdlib/join/
|
||||
list_query_example: join-new
|
||||
---
|
||||
|
||||
{{< duplicate-oss >}}
|
||||
|
|
@ -241,4 +241,5 @@ For users needing stricter security around data access and risk mitigation measu
|
|||
## Compliance and auditing
|
||||
|
||||
InfluxDB Cloud is **SOC2 Type II** certified.
|
||||
To request a copy of our SOC2 Type II report, please email <sales@influxdata.com>.
|
||||
To request a copy of our SOC2 Type II report,
|
||||
or for information on the ISO 27001 Information Security Management System, please email <sales@influxdata.com>.
|
||||
|
|
|
|||
|
|
@ -7,6 +7,8 @@ menu:
|
|||
name: Time Series Index (TSI) overview
|
||||
weight: 70
|
||||
parent: Concepts
|
||||
aliases:
|
||||
- /influxdb/latest/concepts/time-series-index/
|
||||
---
|
||||
|
||||
Find overview and background information on Time Series Index (TSI) in this topic. For detail, including how to enable and configure TSI, see [Time Series Index (TSI) details](/influxdb/v1.8/concepts/tsi-details/).
|
||||
|
|
|
|||
|
|
@ -6,9 +6,12 @@ aliases:
|
|||
- /influxdb/v1.8/introduction/getting_started/
|
||||
- /influxdb/v1.8/introduction/getting-started/
|
||||
- /influxdb/v2.0/introduction/getting-started/
|
||||
- /influxdb/v2.0/introduction/getting_started/
|
||||
- /influxdb/v2.1/introduction/getting-started/
|
||||
- /influxdb/v2.1/introduction/getting_started/
|
||||
- /influxdb/v2.2/introduction/getting_started/
|
||||
- /influxdb/v2.3/introduction/getting_started/
|
||||
- /influxdb/v2.4/introduction/getting_started/
|
||||
- /influxdb/latest/introduction/getting-started/
|
||||
|
||||
menu:
|
||||
influxdb_1_8:
|
||||
name: Get started with InfluxDB
|
||||
|
|
|
|||
|
|
@ -6,6 +6,8 @@ menu:
|
|||
influxdb_1_8:
|
||||
weight: 70
|
||||
identifier: InfluxQL
|
||||
aliases:
|
||||
- /influxdb/latest/query_language/_index
|
||||
---
|
||||
|
||||
This section introduces InfluxQL, the InfluxDB SQL-like query language for
|
||||
|
|
|
|||
|
|
@ -11,6 +11,7 @@ aliases:
|
|||
- /influxdb/v2.1/query_language/spec/
|
||||
- /influxdb/v2.2/query_language/spec/
|
||||
- /influxdb/v2.3/query_language/spec/
|
||||
- /influxdb/v2.4/query_language/spec/
|
||||
- /influxdb/latest/query_language/spec/
|
||||
---
|
||||
|
||||
|
|
|
|||
|
|
@ -14,7 +14,7 @@ Access the InfluxDB API using the `/api/v2/` endpoint.
|
|||
|
||||
## Developer guides
|
||||
|
||||
- [API starter guide](/influxdb/v2.2/api-guide/starter/)
|
||||
- [API Quick Start](/influxdb/v2.2/api-guide/api_intro/)
|
||||
|
||||
## InfluxDB client libraries
|
||||
|
||||
|
|
|
|||
|
|
@ -14,7 +14,7 @@ Access the InfluxDB API using the `/api/v2/` endpoint.
|
|||
|
||||
## Developer guides
|
||||
|
||||
- [API starter guide](/influxdb/v2.3/api-guide/starter/)
|
||||
- [API Quick Start](/influxdb/v2.3/api-guide/api_intro/)
|
||||
|
||||
## InfluxDB client libraries
|
||||
|
||||
|
|
|
|||
|
|
@ -93,13 +93,16 @@ see [Write back to InfluxDB](#write-back-to-influxdb) below.
|
|||
|
||||
## Use Kapacitor stream tasks
|
||||
InfluxDB Cloud and OSS {{< current-version >}} do not have subscription APIs and do not support Kapacitor stream tasks directly.
|
||||
To use Kapacitor stream tasks, write data directly to Kapacitor using the [Kapcitior `write` API](/{{< latest "kapacitor" >}}/working/api/#writing-data).
|
||||
To use Kapacitor stream tasks, write data directly to Kapacitor using the [Kapacitor `write` API](/{{< latest "kapacitor" >}}/working/api/#writing-data). We recommend using the [Telegraf InfluxDB output plugin](/{{< latest "telegraf" >}}/plugins/#output-influxdb) to write data to both InfluxDB Cloud or OSS and Kapacitor.
|
||||
|
||||
We recommend using [Telegraf InfluxDB output plugin](/{{< latest "telegraf" >}}/plugins/#output-influxdb)
|
||||
to write data to both InfluxDB Cloud or OSS and Kapacitor.
|
||||
The following example Telegraf configuration writes data to both InfluxDB and Kapacitor:
|
||||
##### Write data using the Telegraf InfluxDB output plugin
|
||||
|
||||
To write data to both InfluxDB and Kapacitor using the InfluxDB output plugin, complete the following steps:
|
||||
|
||||
1. [Install Telegraf](/{{< latest "telegraf" >}}/install/).
|
||||
2. [Create a DBRP mapping](/influxdb/v2.3/query-data/influxql/dbrp/#create-dbrp-mappings).
|
||||
3. In the [Telegraf InfluxDB output plugin](/{{< latest "telegraf" >}}/plugins/#output-influxdb) configuration file, specify the following options, replacing `database`, `retention_policy`, `username` and `password` to match your DBRP mapping, and set `skip_database_creation` to `true`:
|
||||
|
||||
##### Example Telegraf configuration
|
||||
```toml
|
||||
# Write to Kapacitor
|
||||
[[outputs.influxdb]]
|
||||
|
|
@ -114,6 +117,7 @@ The following example Telegraf configuration writes data to both InfluxDB and Ka
|
|||
retention_policy = "example-rp"
|
||||
username = "influxdb-username"
|
||||
password = "influxdb-token"
|
||||
skip_database_creation = true
|
||||
```
|
||||
|
||||
## Write back to InfluxDB
|
||||
|
|
|
|||
|
|
@ -14,7 +14,7 @@ Access the InfluxDB API using the `/api/v2/` endpoint.
|
|||
|
||||
## Developer guides
|
||||
|
||||
- [API starter guide](/influxdb/v2.4/api-guide/starter/)
|
||||
- [API Quick Start](/influxdb/v2.4/api-guide/api_intro/)
|
||||
|
||||
## InfluxDB client libraries
|
||||
|
||||
|
|
|
|||
|
|
@ -8,6 +8,7 @@ aliases:
|
|||
- /influxdb/v2.4/reference/client-libraries/
|
||||
- /influxdb/v2.4/reference/api/client-libraries/
|
||||
- /influxdb/v2.4/tools/client-libraries/
|
||||
- /influxdb/v2.x/api-guide/client-libraries/
|
||||
menu:
|
||||
influxdb_2_4:
|
||||
name: Client libraries
|
||||
|
|
|
|||
|
|
@ -97,6 +97,7 @@ client = influxdb_client.InfluxDBClient(
|
|||
org=org
|
||||
)
|
||||
|
||||
# Write script
|
||||
write_api = client.write_api(write_options=SYNCHRONOUS)
|
||||
|
||||
p = influxdb_client.Point("my_measurement").tag("location", "Prague").field("temperature", 25.3)
|
||||
|
|
@ -113,11 +114,11 @@ write_api.write(bucket=bucket, org=org, record=p)
|
|||
2. Create a Flux query, and then format it as a Python string.
|
||||
|
||||
```python
|
||||
query = ' from(bucket:"my-bucket")\
|
||||
query = 'from(bucket:"my-bucket")\
|
||||
|> range(start: -10m)\
|
||||
|> filter(fn:(r) => r._measurement == "my_measurement")\
|
||||
|> filter(fn: (r) => r.location == "Prague")\
|
||||
|> filter(fn:(r) => r._field == "temperature" ) '
|
||||
|> filter(fn:(r) => r.location == "Prague")\
|
||||
|> filter(fn:(r) => r._field == "temperature")'
|
||||
```
|
||||
|
||||
The query client sends the Flux query to InfluxDB and returns a Flux object with a table structure.
|
||||
|
|
@ -157,12 +158,28 @@ write_api.write(bucket=bucket, org=org, record=p)
|
|||
### Complete example query script
|
||||
|
||||
```python
|
||||
import influxdb_client
|
||||
from influxdb_client.client.write_api import SYNCHRONOUS
|
||||
|
||||
bucket = "<my-bucket>"
|
||||
org = "<my-org>"
|
||||
token = "<my-token>"
|
||||
# Store the URL of your InfluxDB instance
|
||||
url="http://localhost:8086"
|
||||
|
||||
client = influxdb_client.InfluxDBClient(
|
||||
url=url,
|
||||
token=token,
|
||||
org=org
|
||||
)
|
||||
|
||||
# Query script
|
||||
query_api = client.query_api()
|
||||
query = ‘ from(bucket:"my-bucket")\
|
||||
query = 'from(bucket:"my-bucket")\
|
||||
|> range(start: -10m)\
|
||||
|> filter(fn:(r) => r._measurement == "my_measurement")\
|
||||
|> filter(fn: (r) => r.location == "Prague")\
|
||||
|> filter(fn:(r) => r._field == "temperature" )‘
|
||||
|> filter(fn:(r) => r.location == "Prague")\
|
||||
|> filter(fn:(r) => r._field == "temperature")'
|
||||
result = query_api.query(org=org, query=query)
|
||||
results = []
|
||||
for table in result:
|
||||
|
|
|
|||
|
|
@ -18,7 +18,8 @@ related:
|
|||
- /{{< latest "flux" >}}/join-data/right-outer/
|
||||
- /{{< latest "flux" >}}/join-data/full-outer/
|
||||
- /{{< latest "flux" >}}/join-data/time/
|
||||
list_query_example: join
|
||||
- /{{< latest "flux" >}}/stdlib/join/
|
||||
list_query_example: join-new
|
||||
---
|
||||
|
||||
Use the Flux [`join` package](/{{< latest "flux" >}}/stdlib/join/) to join two data sets
|
||||
|
|
|
|||
|
|
@ -37,7 +37,7 @@ Rows that evaluate to `false` are **excluded** from the output data.
|
|||
|
||||
```js
|
||||
// ...
|
||||
|> filter(fn: (r) => r._measurement == "example-measurement" )
|
||||
|> filter(fn: (r) => r._measurement == "example-measurement-name" )
|
||||
```
|
||||
|
||||
The `fn` predicate function requires an `r` argument, which represents each row
|
||||
|
|
@ -71,6 +71,6 @@ and `filter()` represent the most basic Flux query:
|
|||
```js
|
||||
from(bucket: "example-bucket")
|
||||
|> range(start: -1h)
|
||||
|> filter(fn: (r) => r._measurement == "example-measurement" and r.tag == "example-tag")
|
||||
|> filter(fn: (r) => r._field == "example-field")
|
||||
|> filter(fn: (r) => r._measurement == "example-measurement-name" and r.mytagname == "example-tag-value")
|
||||
|> filter(fn: (r) => r._field == "example-field-name")
|
||||
```
|
||||
|
|
|
|||
|
|
@ -21,10 +21,21 @@ from an InfluxDB bucket in a specified time range.
|
|||
Select points to delete within the specified time range using [delete predicate syntax](/influxdb/v2.4/reference/syntax/delete-predicate).
|
||||
|
||||
{{% warn %}}
|
||||
#### Deleting data without a delete predicate
|
||||
|
||||
Running `influx delete` without the `-p` or `--predicate` flag deletes all data with timestamps between the specified
|
||||
`--start` and `--stop` times in the specified bucket.
|
||||
|
||||
{{% oss-only %}}
|
||||
|
||||
#### Cannot delete data by field
|
||||
|
||||
InfluxDB {{< current-version >}} does not support deleting data **by field**.
|
||||
|
||||
{{% /oss-only %}}
|
||||
{{% /warn %}}
|
||||
|
||||
|
||||
## Flags
|
||||
| Flag | | Description | Input type | {{< cli/mapped >}} |
|
||||
|:-----|:------------------|:----------------------------------------------------------------------------------------------------------|:----------:|:----------------------|
|
||||
|
|
|
|||
|
|
@ -123,10 +123,8 @@ In **extended annotated CSV**, measurements, fields, and values and their types
|
|||
##### Write line protocol via stdin
|
||||
```sh
|
||||
influx write --bucket example-bucket "
|
||||
m,host=host1 field1=1.2
|
||||
m,host=host2 field1=2.4
|
||||
m,host=host1 field2=5i
|
||||
m,host=host2 field2=3i
|
||||
m,host=host1 field1=1.2,field2=5i 1640995200000000000
|
||||
m,host=host2 field1=2.4,field2=3i 1640995200000000000
|
||||
"
|
||||
```
|
||||
|
||||
|
|
|
|||
|
|
@ -69,7 +69,7 @@ The [WAL](#write-ahead-log-wal) and cache are separate entities and do not inter
|
|||
|
||||
The cache:
|
||||
|
||||
- Organizes points by key (measurement, tag set, and unique field)
|
||||
- Organizes points by key (measurement, tag set, and unique field).
|
||||
Each field is stored in its own time-ordered range.
|
||||
- Stores uncompressed data.
|
||||
- Gets updates from the WAL each time the storage engine restarts.
|
||||
|
|
|
|||
|
|
@ -31,9 +31,22 @@ Use [logical operators](#logical-operators) to combine two or more predicate exp
|
|||
```sql
|
||||
key1="value1" AND key2="value"
|
||||
```
|
||||
|
||||
{{% warn %}}
|
||||
With **InfluxDB {{< current-version >}}**, delete predicates can use any column
|
||||
or tag **except** `_time`{{% oss-only %}}, `_field`, {{% /oss-only %}}or `_value`.
|
||||
#### Column limitations when deleting data
|
||||
**InfluxDB {{< current-version >}}** supports deleting data by any column or tag
|
||||
_**except**_ the following:
|
||||
|
||||
- `_time`
|
||||
- {{% oss-only %}}`_field`{{% /oss-only %}}
|
||||
- `_value`
|
||||
|
||||
{{% oss-only %}}
|
||||
|
||||
_InfluxDB {{< current-version >}} does not support deleting data **by field**._
|
||||
|
||||
{{% /oss-only %}}
|
||||
|
||||
{{% /warn %}}
|
||||
|
||||
## Logical operators
|
||||
|
|
|
|||
|
|
@ -93,13 +93,16 @@ see [Write back to InfluxDB](#write-back-to-influxdb) below.
|
|||
|
||||
## Use Kapacitor stream tasks
|
||||
InfluxDB Cloud and OSS {{< current-version >}} do not have subscription APIs and do not support Kapacitor stream tasks directly.
|
||||
To use Kapacitor stream tasks, write data directly to Kapacitor using the [Kapcitior `write` API](/{{< latest "kapacitor" >}}/working/api/#writing-data).
|
||||
To use Kapacitor stream tasks, write data directly to Kapacitor using the [Kapacitor `write` API](/{{< latest "kapacitor" >}}/working/api/#writing-data). We recommend using the [Telegraf InfluxDB output plugin](/{{< latest "telegraf" >}}/plugins/#output-influxdb) to write data to both InfluxDB Cloud or OSS and Kapacitor.
|
||||
|
||||
We recommend using [Telegraf InfluxDB output plugin](/{{< latest "telegraf" >}}/plugins/#output-influxdb)
|
||||
to write data to both InfluxDB Cloud or OSS and Kapacitor.
|
||||
The following example Telegraf configuration writes data to both InfluxDB and Kapacitor:
|
||||
##### Write data using the Telegraf InfluxDB output plugin
|
||||
|
||||
To write data to both InfluxDB and Kapacitor using the InfluxDB output plugin, complete the following steps:
|
||||
|
||||
1. [Install Telegraf](/{{< latest "telegraf" >}}/install/).
|
||||
2. [Create a DBRP mapping](/influxdb/v2.4/query-data/influxql/dbrp/#create-dbrp-mappings).
|
||||
3. In the [Telegraf InfluxDB output plugin](/{{< latest "telegraf" >}}/plugins/#output-influxdb) configuration file, specify the following options, replacing `database`, `retention_policy`, `username` and `password` to match your DBRP mapping, and set `skip_database_creation` to `true`:
|
||||
|
||||
##### Example Telegraf configuration
|
||||
```toml
|
||||
# Write to Kapacitor
|
||||
[[outputs.influxdb]]
|
||||
|
|
@ -114,6 +117,7 @@ The following example Telegraf configuration writes data to both InfluxDB and Ka
|
|||
retention_policy = "example-rp"
|
||||
username = "influxdb-username"
|
||||
password = "influxdb-token"
|
||||
skip_database_creation = true
|
||||
```
|
||||
|
||||
## Write back to InfluxDB
|
||||
|
|
|
|||
|
|
@ -46,6 +46,7 @@ Consider whether you need to address any of the following before upgrading.
|
|||
- [Other data](#other-data)
|
||||
- [Secure by default](#secure-by-default)
|
||||
- [`inmem` indexing option](#in-memory-indexing-option)
|
||||
- [Interactive shell](#interactive-shell)
|
||||
|
||||
### Available operating system, container, and platform support
|
||||
|
||||
|
|
@ -174,7 +175,20 @@ InfluxDB {{< current-version >}} doesn't support [in-memory (`inmem`) indexing](
|
|||
|
||||
### Interactive shell
|
||||
|
||||
The InfluxDB 2.x `influx` CLI does not include an interactive shell for executing InfluxQL queries or Flux queries. For information about executing InfluxQL queries, see [Query data with InfluxQL](/influxdb/v2.4/query-data/influxql/). To build an interactive shell to execute Flux queries, [compile and build a command line Flux REPL from source](https://github.com/influxdata/flux/blob/master/README.md#getting-started).
|
||||
The InfluxDB {{< current-version >}} `influx` CLI includes an interactive **InfluxQL shell** for executing InfluxQL queries.
|
||||
To start an InfluxQL shell:
|
||||
|
||||
1. Download and install in the [`influx` CLI](/influxdb/v2.4/tools/influx-cli/).
|
||||
2. Set up your [`influx` CLI authentication credentials](/influxdb/v2.4/tools/influx-cli/#set-up-the-influx-cli).
|
||||
3. Run the `influx v1 shell` command.
|
||||
|
||||
For more information see:
|
||||
|
||||
- [Use the InfluxQL shell](/influxdb/v2.4/tools/influxql-shell/)
|
||||
- [Query data with InfluxQL](/influxdb/v2.4/query-data/influxql/)
|
||||
|
||||
To build an interactive shell to execute **Flux** queries,
|
||||
[compile and build a command line Flux REPL from source](https://github.com/influxdata/flux/blob/master/README.md#getting-started).
|
||||
|
||||
## Perform the upgrade
|
||||
|
||||
|
|
|
|||
|
|
@ -18,6 +18,7 @@ to update InfluxDB 1.x Docker deployments to InfluxDB 2.x.
|
|||
- [Minimal upgrade](#minimal-upgrade)
|
||||
- [Upgrade with a custom InfluxDB 1.x configuration file](#upgrade-with-a-custom-influxdb-1-x-configuration-file)
|
||||
- [Upgrade with custom paths](#upgrade-with-custom-paths)
|
||||
- [Use new InfluxDB tools](#use-new-influxdb-tools)
|
||||
|
||||
{{% note %}}
|
||||
#### Export continuous queries before upgrading
|
||||
|
|
@ -249,3 +250,41 @@ docker run -p 8086:8086 \
|
|||
{{% /tab-content %}}
|
||||
<!--------------------------- END USE 2.x DEFAULTS ---------------------------->
|
||||
{{< /tabs-wrapper >}}
|
||||
|
||||
## Use new InfluxDB tools
|
||||
|
||||
Once upgraded, use InfluxDB {{< current-version >}} tools to work with your time series data.
|
||||
|
||||
- [Migrate continuous queries to tasks](#migrate-continuous-queries-to-tasks)
|
||||
- [Use the interactive InfluxQL shell](#use-the-interactive-influxql-shell)
|
||||
|
||||
### Migrate continuous queries to tasks
|
||||
|
||||
InfluxDB {{< current-version >}} replaces continuous queries with **tasks**.
|
||||
By default, the upgrade process writes all continuous queries to `~/continuous_queries.txt`.
|
||||
To convert continuous queries to InfluxDB tasks, see
|
||||
[Migrate continuous queries to tasks](/influxdb/v2.4/upgrade/v1-to-v2/migrate-cqs/).
|
||||
|
||||
### Use the interactive InfluxQL shell
|
||||
|
||||
The InfluxDB {{< current-version >}} `influx` CLI includes an interactive **InfluxQL shell** for executing InfluxQL queries.
|
||||
The InfluxDB {{< current-version >}} Docker image includes the `influx` CLI.
|
||||
|
||||
To start an InfluxQL shell:
|
||||
|
||||
1. Start a bash session in your InfluxDB container:
|
||||
|
||||
```sh
|
||||
docker exec -it influxdb /bin/bash
|
||||
```
|
||||
|
||||
2. Set up your [`influx` CLI authentication credentials](/influxdb/v2.4/tools/influx-cli/#set-up-the-influx-cli).
|
||||
3. Run the `influx v1 shell` command.
|
||||
|
||||
For more information, see:
|
||||
|
||||
- [Use the InfluxQL shell](/influxdb/v2.4/tools/influxql-shell/)
|
||||
- [Query data with InfluxQL](/influxdb/v2.4/query-data/influxql/)
|
||||
|
||||
To build an interactive shell to execute **Flux** queries,
|
||||
[compile and build a command line Flux REPL from source](https://github.com/influxdata/flux/blob/master/README.md#getting-started).
|
||||
|
|
|
|||
|
|
@ -23,6 +23,7 @@ To manually upgrade from InfluxDB 1.x to InfluxDB {{< current-version >}}:
|
|||
4. [Create authorizations](#create-authorizations)
|
||||
5. [Migrate time series data](#migrate-time-series-data)
|
||||
6. [Migrate continuous queries](#migrate-continuous-queries)
|
||||
7. [Query data with InfluxQL](#query-data-with-influxql)
|
||||
|
||||
## Install InfluxDB {{< current-version >}}
|
||||
[Download, install, and set up InfluxDB {{< current-version >}}](/influxdb/v2.4/get-started/).
|
||||
|
|
@ -75,7 +76,7 @@ If you're using custom configuration settings in your InfluxDB 1.x instance, do
|
|||
| | |
|
||||
| **[http]** | |
|
||||
| flux-enabled | |
|
||||
| flux-log-enabled | |
|
||||
| flux-log-enabled | [flux-log-enabled](/influxdb/v2.4/reference/config-options/#flux-log-enabled) |
|
||||
| bind-address | [http-bind-address](/influxdb/v2.4/reference/config-options/#http-bind-address) |
|
||||
| auth-enabled | |
|
||||
| realm | |
|
||||
|
|
@ -337,3 +338,9 @@ To migrate time series data from your InfluxDB 1.x instance to InfluxDB {{< curr
|
|||
## Migrate continuous queries
|
||||
For information about migrating InfluxDB 1.x continuous queries to InfluxDB {{< current-version >}} tasks,
|
||||
see [Migrate continuous queries to tasks](/influxdb/v2.4/upgrade/v1-to-v2/migrate-cqs/).
|
||||
|
||||
## Query data with InfluxQL
|
||||
|
||||
InfluxDB {{< current-version >}} supports querying data with both Flux and InfluxQL.
|
||||
For more information about querying InfluxDB {{< current-version >}} with InfluxQL,
|
||||
see [Query data with InfluxQL](/influxdb/v2.4/query-data/influxql/).
|
||||
|
|
|
|||
|
|
@ -32,7 +32,8 @@ InfluxDB {{< current-version >}} supports deleting data by the following:
|
|||
{{% oss-only %}}
|
||||
|
||||
{{% warn %}}
|
||||
InfluxDB {{< current-version >}} does not support deleting data by field.
|
||||
#### Cannot delete data by field
|
||||
InfluxDB {{< current-version >}} does not support deleting data **by field**.
|
||||
{{% /warn %}}
|
||||
|
||||
{{% /oss-only %}}
|
||||
|
|
@ -76,6 +77,10 @@ deletes all data in the specified bucket with timestamps between the specified `
|
|||
|
||||
### Examples
|
||||
|
||||
- [Delete points in a specific measurement with a specific tag value](#delete-points-in-a-specific-measurement-with-a-specific-tag-value)
|
||||
- [Delete all points in a specified time range](#delete-all-points-in-a-specified-time-range)
|
||||
- {{% cloud-only %}}[Delete points for a specific field in a specified time range](#delete-points-for-a-specific-field-in-a-specified-time-range){{% /cloud-only %}}
|
||||
|
||||
##### Delete points in a specific measurement with a specific tag value
|
||||
```sh
|
||||
influx delete --bucket example-bucket \
|
||||
|
|
@ -91,6 +96,18 @@ influx delete --bucket example-bucket \
|
|||
--stop 2020-11-14T00:00:00Z
|
||||
```
|
||||
|
||||
{{% cloud-only %}}
|
||||
|
||||
##### Delete points for a specific field in a specified time range
|
||||
```sh
|
||||
influx delete --bucket example-bucket \
|
||||
--start 2022-01-01T00:00:00Z \
|
||||
--stop 2022-02-01T00:00:00Z \
|
||||
--predicate '_field="example-field"'
|
||||
```
|
||||
|
||||
{{% /cloud-only %}}
|
||||
|
||||
## Delete data using the API
|
||||
Use the InfluxDB API [`/api/v2/delete` endpoint](/influxdb/v2.4/api/#operation/PostDelete)
|
||||
to delete points from InfluxDB.
|
||||
|
|
@ -119,6 +136,10 @@ deletes all data in the specified bucket with timestamps between the specified `
|
|||
|
||||
### Examples
|
||||
|
||||
- [Delete points in a specific measurement with a specific tag value](#delete-points-in-a-specific-measurement-with-a-specific-tag-value-1)
|
||||
- [Delete all points in a specified time range](#delete-all-points-in-a-specified-time-range-1)
|
||||
- {{% cloud-only %}}[Delete points for a specific field in a specified time range](#delete-points-for-a-specific-field-in-a-specified-time-range-1){{% /cloud-only %}}
|
||||
|
||||
##### Delete points in a specific measurement with a specific tag value
|
||||
```sh
|
||||
curl --request POST http://localhost:8086/api/v2/delete?org=example-org&bucket=example-bucket \
|
||||
|
|
@ -142,4 +163,20 @@ curl --request POST http://localhost:8086/api/v2/delete?org=example-org&bucket=e
|
|||
}'
|
||||
```
|
||||
|
||||
{{% cloud-only %}}
|
||||
|
||||
##### Delete points for a specific field in a specified time range
|
||||
```sh
|
||||
curl --request POST http://localhost:8086/api/v2/delete?org=example-org&bucket=example-bucket \
|
||||
--header 'Authorization: Token YOUR_API_TOKEN' \
|
||||
--header 'Content-Type: application/json' \
|
||||
--data '{
|
||||
"start": "2022-01-01T00:00:00Z",
|
||||
"stop": "2022-02-01T00:00:00Z",
|
||||
"predicate": "_field=\"example-field\""
|
||||
}'
|
||||
```
|
||||
|
||||
{{% /cloud-only %}}
|
||||
|
||||
_For more information, see the [`/api/v2/delete` endpoint documentation](/influxdb/v2.4/api/#operation/PostDelete)._
|
||||
|
|
|
|||
|
|
@ -10,7 +10,11 @@ menu:
|
|||
weight: 10
|
||||
weight: 6
|
||||
aliases:
|
||||
|
||||
- /telegraf/v1.24/plugins/processors/
|
||||
- /telegraf/v1.24/plugins/plugins-list/
|
||||
- /telegraf/v1.24/plugins/aggregators/
|
||||
- /telegraf/v1.24/plugins/outputs/
|
||||
- /telegraf/v1.24/plugins/inputs/
|
||||
- /telegraf/v1.23/plugins/plugins-list/
|
||||
- /telegraf/v1.23/plugins/aggregators/
|
||||
- /telegraf/v1.23/plugins/inputs/
|
||||
|
|
|
|||
|
|
@ -1,9 +1,9 @@
|
|||
---
|
||||
title: Telegraf 1.23 release notes
|
||||
title: Telegraf 1.24 release notes
|
||||
description: Important features and changes in the latest version of Telegraf.
|
||||
aliases:
|
||||
- /telegraf/v1.23/reference/release-notes/influxdb/
|
||||
- /telegraf/v1.23/about_the_project/release-notes-changelog/
|
||||
- /telegraf/v1.24/reference/release-notes/influxdb/
|
||||
- /telegraf/v1.24/about_the_project/release-notes-changelog/
|
||||
menu:
|
||||
telegraf_1_24_ref:
|
||||
|
||||
|
|
|
|||
|
|
@ -237,7 +237,7 @@ interpolate_linear:
|
|||
| 2021-01-08T00:00:00Z | 80.0 |
|
||||
| 2021-01-09T00:00:00Z | 90.0 |
|
||||
|
||||
join:
|
||||
join-new:
|
||||
-
|
||||
code: |
|
||||
```js
|
||||
|
|
@ -302,6 +302,43 @@ join:
|
|||
| 2020-01-01T00:03:00Z | 5678 | 1 | true |
|
||||
| 2020-01-01T00:04:00Z | 5678 | 8 | true |
|
||||
|
||||
join:
|
||||
-
|
||||
code: |
|
||||
```js
|
||||
t1 = from(bucket: "example-bucket")
|
||||
|> range(start: 2020-01-01T00:00:00Z)
|
||||
|> filter(fn: (r) => r.m == "foo")
|
||||
|
||||
t2 = from(bucket: "example-bucket")
|
||||
|> range(start: 2020-01-01T00:00:00Z)
|
||||
|> filter(fn: (r) => r.m == "bar")
|
||||
|
||||
join(tables: {t1: t1, t2: t2}, on: ["_time"])
|
||||
```
|
||||
input: |
|
||||
###### t1
|
||||
| _time | _value |
|
||||
|:----- | ------:|
|
||||
| 2020-01-01T00:01:00Z | 1 |
|
||||
| 2020-01-01T00:02:00Z | 2 |
|
||||
| 2020-01-01T00:03:00Z | 1 |
|
||||
| 2020-01-01T00:04:00Z | 3 |
|
||||
###### t2
|
||||
| _time | _value |
|
||||
|:----- | ------:|
|
||||
| 2020-01-01T00:01:00Z | 5 |
|
||||
| 2020-01-01T00:02:00Z | 2 |
|
||||
| 2020-01-01T00:03:00Z | 3 |
|
||||
| 2020-01-01T00:04:00Z | 4 |
|
||||
output: |
|
||||
| _time | _value_t1 | _value_t2 |
|
||||
|:----- | ---------:| ---------:|
|
||||
| 2020-01-01T00:01:00Z | 1 | 5 |
|
||||
| 2020-01-01T00:02:00Z | 2 | 2 |
|
||||
| 2020-01-01T00:03:00Z | 1 | 3 |
|
||||
| 2020-01-01T00:04:00Z | 3 | 4 |
|
||||
|
||||
map_math:
|
||||
-
|
||||
code: |
|
||||
|
|
|
|||
|
|
@ -1739,13 +1739,6 @@ input:
|
|||
link: https://github.com/influxdata/telegraf/blob/master/plugins/inputs/slab/README.md
|
||||
tags: [linux, system]
|
||||
|
||||
- name: SMCIPMITool
|
||||
id: smc_ipmi
|
||||
description: |
|
||||
The SMCIPMITool input plugin parses the output of [SMCIPMITool](https://www.supermicro.com/en/solutions/management-software/ipmi-utilities).
|
||||
introduced: 1.18.0
|
||||
tags: [linux, macos, windows, servers, networking]
|
||||
|
||||
- name: S.M.A.R.T.
|
||||
id: smart
|
||||
description: |
|
||||
|
|
|
|||
|
|
@ -1 +1,2 @@
|
|||
User-agent: *{{ if eq .Site.Params.environment "staging" }} Disallow: /{{ end }}
|
||||
User-agent: *
|
||||
{{ if eq .Site.Params.environment "staging" }}Disallow: /{{ end }}
|
||||
Loading…
Reference in New Issue