Hi

 

Would the following scenario be reasonable:

 

1.)    Kafka Spout 

2.)    Storm Bolt for storing active devices in and deleting inactive
devices from Redis

3.)    Storm Bolt with tick tuple for pulling the active devices from Redis
every minute

4.)    Storm Bolt to calculate from the actual time and the timestamp from
the device start at which point the device is at the moment, depending on
this point the currently valid value can be found within another database

5.)    Storm Bolt for looking up the current value depending on the
calculation of 4.)

6.)    Storm Bolt for calculating the sum over all current values

 

Thank you in advance.

 

Regards,

Daniela

 

 

Reply via email to