Hello,
I am trying to generate a task that calculates the series cardinality on InfluxdB OSS. The same is running on other InfluxDB instances that I am using but failing for this particular instance.
import “influxdata/influxdb”
option task = {
name: “Series cardinality”,
every: 1d,
}
dest_bucket = “Cardinality”
dest_measurement = “series_cardinality”
organization = " ****"
bucketCardinality = (bucket) =>
(influxdb.cardinality(bucket: bucket, start: time(v: 0))
|> findColumn(fn: (key) => true, column: "value"))[0]
buckets()
|> filter(fn: (r) => not r.name =~ /^/)
|> map(fn: (r) => ({bucket: r.name, “Total_Cardinality”: bucketCardinality(bucket: r.name)}))
|> sum(column: “Total_Cardinality”)
|> set(key: “_time”, value: string(v: now()))
|> map(
fn: (r) =>
({
_value: r.Total_Cardinality,
_measurement: dest_measurement,
_field: “series_cardinality”,
_time: time(v: r._time),
}),
)
|> to(bucket: dest_bucket, org: organization, timeColumn: “_time”)
The error I am getting is pasted below:
Kindly suggest what changes need to be made here.
Thanks
