Derivative InfluxQL to Flux conversion

Fluxlang
1

Just to be sure i’m on the same page, could someone show me the equivalent Flux queries for the below influxql ones? I use them to get byte counters from influxdb and draw gigabit per second graphs grouped by node name.

SELECT non_negative_derivative(sum(“dnlnk-bytes”), 5m) *8/300 AS “apn dnlk+uplk” FROM “apnSch1” WHERE $timeFilter GROUP BY time(5m), node fill(null)

SELECT non_negative_derivative(max(“rxbytes”), 5m) *8/300 FROM “portSch1” WHERE $timeFilter GROUP BY time(5m), node fill(null)

Thank you)

2

@aserkin I believe these are the equivalent Flux queries:

from(bucket: "example-bucket")
    |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
    |> filter(fn: (r) => r._measurement == "apnSch1" and r._field == "dnlnk-bytes")
    |> group(columns: ["node"])
    |> aggregateWindow(every: 5m, fn: sum)
    |> derivative(nonNegative: true)
    |> map(fn: (r) => ({r with _value: r._value * 8.0 / 300.0}))
    |> set(key: "_field", value: "apn dnlk+uplk")

from(bucket: "example-bucket")
    |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
    |> filter(fn: (r) => r._measurement == "portSch1" and r._field == "rxbytes")
    |> group(columns: ["node"])
    |> aggregateWindow(every: 5m, fn: max)
    |> derivative(nonNegative: true)
    |> map(fn: (r) => ({r with _value: r._value * 8.0 / 300.0}))