dbrp “bb_db”.“autogen”
var stream_obj_1 = stream |from().database(‘bb_db’).measurement(‘HeartRate’).where(lambda: “ip_addr” == ‘192.168.50.238’ AND “component” == ‘Bio_Sensors’)
stream_obj_1
|eval(lambda: int(“stream_obj_1.bpm”) < 90)
.as(‘alarm_state’)
.keep(‘bpm’)
|alert()
.crit(lambda: int(“stream_obj_1.bpm”) < 90)
.message(’’)
.stateChangesOnly()
.log(’/tmp/alerts.log’)
|influxDBOut()
.database(‘bb_db’)
.measurement(‘sampletable’)
.tag(‘message’, ‘’)