Hi StreamPipes devs,
we have a Use Case where we must notice and fire an appropriate event
when one of our customer's sensors stops streaming (no new messages in x
minutes). What makes this complicated is that all sensors stream to one
MQTT topic on an MQTT broker. The ID of the sensor that sent a message
is then in one of the keys of the data. If I understand it correctly,
this restriction makes using the "Stream Stop Detector" Processor
impossible.
It is not feasible to create one SP Pipeline per sensor, since that
number could grow quickly.
I have played around with the current Pipeline Elements but couldn't
figure out how I would go about implementing that functionality.
Does the project have a way to deal with such a case already? If not,
has this already been discussed? Does maybe anybody have an idea how we
could go about getting this functionality without resorting to writing
code that runs outside of StreamPipes?
Thanks in advance,
Dominick
--
*EDI GmbH*
/Engineering Data Intelligence/
Hermann-Weick-Weg 3
76229 Karlsruhe (Grötzingen), Deutschland
Dominick Madden
Senior Backend Developer
Telefon: +49 721 79199 155
Email: [email protected]
WWW: www <http://www.edi.gmbh/en/>. <http://www.edi.gmbh/en/>edi.gmbh
<http://www.edi.gmbh/en/>
<https://www.youtube.com/channel/UCaLsW2mgWB3BB8isicyqU6g?view_as=subscriber>linkdein
<https://www.linkedin.com/authwall?trk=ripf&trkInfo=AQEzpm6QRZtfBwAAAXaG-GNQu9A0kNpT5EDSPJWHJJdrGfQWIQkO6aw4SCy1fkWaYk9JsvuRCRdMHe30l4tZpPkDAKWlnjiA1OIvsvMogKwGpP4h36ZJBkNfWRakUrXQi_ES-Ig=&originalReferer=&sessionRedirect=https%3A%2F%2Fwww.linkedin.com%2Fcompany%2Fengineering-data-intelligence>
youtube <https://www.youtube.com/channel/UCaLsW2mgWB3BB8isicyqU6g>
digitalisation 100 orte opc
Die EDI GmbH wird vertreten durchdie Geschäftsführer Dr.-Ing.
MohanadEl-Haji und Dr.-Ing. ThomasFreudenmann.
Sitz der Gesellschaft ist Karlsruhe,HRB 723936 (Registergericht AGMannheim)
<http://www.edi.gmbh/en/>
