Help with InfluxDB error

KaiJ17 · May 9, 2022, 5:31am

Hi all,

I am currently trying to Make this script a Task, using this script that acts as an alert, i would send an Notification to telegram. But however, it only sends the notification when i click submit or hover back and forth from one query to another. i followed this Link to create this script.

Also while saving this script as a Task, i encountered this issue, if anyone knows what is going on or what am i doing wrong please feel free to comment. Much Help Appreciated!!

Anaisdg · May 10, 2022, 8:40pm

Hello @KaiJ17,
hmm that’s odd.
Can you try copy and paste your flux script into a task through the task UI? Its the little calendar icon on the bar menu on the left hand side.

But also change
the start time to be -task.every instead of hard coded times.

Finally, this might be useful to you:

github.com/influxdata/flux

Task without tables returned to client, bypass error invoking streaming functions

opened 09:40PM - 17 May 21 UTC

Anaisdg

The following task works as expected, so I'd like to bypass the expectation to r…eturn tables from a task for such a use case. The task sends a slack alert when a usage event happens. Thank you!! ``` import "csv" import "math" import "date" import "strings" import "experimental/json" import "experimental/usage" import "slack" option task = {name: "Cardinality Alert", every: 1h, offset: 1m} slackWebhook = "https://hooks.slack.com/services/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" slackChannel = "" alert = (eventValue, threshold) => (if eventValue >= threshold then slack.message( url: slackWebhook, channel: slackChannel, text: "A Cardinality Event has occured! The number of cardinality events = \"${string(v: eventValue)}\".", color: "warning", ) else 0) data = usage.from(start: -task.every, stop: now()) |> filter(fn: (r) => (r._measurement == "events" and r._field == "event_type_limited_cardinality" and exists r._value)) |> sum() |> last() |> findRecord(fn: (key) => (true), idx: 0) event = data._value alert(eventValue: event, threshold: 1) ``` But I get the following error: ``` Error exhausting result iterator; Err: error in query specification while starting program: this Flux script returns no streaming data. Consider adding a "yield" or invoking streaming functions directly, without performing an assignment: error in query specification while starting program: this Flux script returns no streaming data. Consider adding a "yield" or invoking streaming functions directly, without performing an assignment ```

You might need to add:

import "array"
array.from(rows: [{v: 0}]) |> yield(name: "trivial")

KaiJ17 · May 11, 2022, 1:28am

Hello @Anaisdg,

Thanks for the Suggestions, for the first step that you gave i have already done it which shown in the picture below. I get another error but now the error is different.

For the second step which u suggest array, can you guide me on that because I’m not very clear on that step and not familiar with that function. Is it possible to tell me where to add my array or so. That would be great help.

Thank you!

Topic		Replies	Views
Simple Alert as a Task Example with telegram InfluxDB 2	12	1419	June 14, 2022
Simple task alert slack example InfluxDB 2 flux	3	1383	December 1, 2020
Task Query Issue Tasks tasks	1	703	January 29, 2022
InfluxDB with telegram bot as HTTP endpoint InfluxDB 2	2	1141	May 10, 2022
Task sending alerts randomly InfluxDB 2 influxdb , query , flux , tasks	1	291	October 13, 2023

Help with InfluxDB error

Related topics