Substitution for Inner Join

Store
10

Hi Steve,

sorry for the very late answer. If your question is still valid, my Kapacitor script for inner joining two measurements separated by the tags “field1” and “field2” looks like the following:

var field1 = batch
    |query('select mean(value) from "data"."autogen".linedata where prettyname = \'Field Nr 1\'')
    .period(1d).every(1d).groupBy(time(1h)).fill(0)
var field2 = batch
    |query('select mean(value) from "data"."autogen".linedata where prettyname = \'Field Nr 2\'')
    .period(1d).every(1d).groupBy(time(1h)).fill(0)

field1
    |join(field2).as('field1', 'field2')
    |eval(lambda: max(("field1.mean" - "field2.mean") * 3.144, 0.0)).as('value')
    |influxDBOut().database('data').measurement('linedata').tag('prettyname', 'Field Nr 3')

Greetings