Hi,
I like to get a device id from one database in one stream and use this for the id filter in another stream. This is the code that I use but it doesn´t seem to work and gives an error: undefined identifier inputID. I’m still new to using influxdb and was wondering if what I’m trying to do is possible and how I could accomplish this.
stream1 = from(bucket: “Bucket1”)
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: ® => r["_measurement"] == “measurement1”)
|> filter(fn: ® => r["_field"] == “name”)
|> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: “_value”)
|> filter(fn: ® => r.name== v.name)
|> keep(columns: [“id”])
|> rename(columns: {id: “inputID”})
|> yield(name: “inputID”)
stream2 = from(bucket: “Bucket2”)
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: ® => r["_measurement"] == “measurement2”)
|> filter(fn: ® => r["_field"] == “name”)
|> filter(fn: ® => r[“id”] == r.inputID)
|> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: “_value”)
|> yield(name: “output”)