docs-v2/content/flux/v0/stdlib/influxdata/influxdb/v1/json.md

3.6 KiB

title description menu weight flux/v0/tags
v1.json() function `v1.json()` parses an InfluxDB 1.x JSON result into a stream of tables.
flux_v0_ref
name parent identifier
v1.json influxdata/influxdb/v1 influxdata/influxdb/v1/json
301
inputs

v1.json() parses an InfluxDB 1.x JSON result into a stream of tables.

Function type signature
(?file: string, ?json: string) => stream[A] where A: Record

{{% caption %}} For more information, see Function type signatures. {{% /caption %}}

Parameters

json

InfluxDB 1.x query results in JSON format.

json and file are mutually exclusive.

file

File path to file containing InfluxDB 1.x query results in JSON format.

The path can be absolute or relative. If relative, it is relative to the working directory of the fluxd process. The JSON file must exist in the same file system running the fluxd process. Note: InfluxDB OSS and InfluxDB Cloud do not support the file parameter. Neither allow access to the underlying filesystem.

Examples

Convert a InfluxDB 1.x JSON query output string to a stream of tables

import "influxdata/influxdb/v1"

jsonData =
    "{
    \"results\": [
        {
            \"statement_id\": 0,
            \"series\": [
                {
                    \"name\": \"cpu_load_short\",
                    \"columns\": [
                        \"time\",
                        \"value\"
                    ],
                    \"values\": [
                        [
                            \"2021-01-01T00:00:00.000000000Z\",
                            2
                        ],
                        [
                            \"2021-01-01T00:01:00.000000000Z\",
                            0.55
                        ],
                        [
                            \"2021-01-01T00:02:00.000000000Z\",
                            0.64
                        ]
                    ]
                }
            ]
        }
    ]
}"

v1.json(json: jsonData)

{{< expand-wrapper >}} {{% expand "View example output" %}}

Output data

_time *_measurement *_field _value
2021-01-01T00:00:00Z cpu_load_short value 2
2021-01-01T00:01:00Z cpu_load_short value 0.55
2021-01-01T00:02:00Z cpu_load_short value 0.64

{{% /expand %}} {{< /expand-wrapper >}}

Convert a InfluxDB 1.x JSON query output file to a stream of tables

import "influxdata/influxdb/v1"

v1.json(file: "/path/to/results.json")