influxdata / influxdata/kapacitor
Need help in TickScript for using the output of one pipeline into another
- Dominant language
- Go
- Stars
- 2.4k
- Forks
- 479
- Avg merge
- 4d 16h
- Merged PRs (30d)
- 4
Description
I am trying to use the output of one pipeline into another pipeline for my lambda expression. This is what I am doing
```
var datastream = stream
|from()
.database('database')
.measurement('measurement')
|groupBy('function')
var runningSD = datastream
|stddev('value')
.as('SD')
var difference = datastream
|difference('value')
.as('difference')
// Here I want to use the output of ruuningSD pipeline for my alert node such as
// |alert()
// .info(lambda: difference/runningSD > 0)
```
Is this possible to do in TickScript? One way I can think of is using eval node and its `keep` property but I am not sure if we can calculate running standard deviation using lambda expression in eval node.
Contributor guide
Research direction
Start with the TickScript datastream, runningSD, difference, alert, and eval nodes shown in the example, especially eval's keep property and lambda expressions. Determine whether one pipeline's standard-deviation output can be used in the other pipeline, and document the supported approach or the limitation.
Written by the indexing model from the issue text.
Assessment
- Domain
- observability, stream-processing
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 15/100