influxdata / influxdata/kapacitor

Need help in TickScript for using the output of one pipeline into another

Open
#2,034 1 comment 0 reactions 0 assignees View on GitHub
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

Open the contributing 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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.