AMQP - Spark Streaming

real time "temperature" analysis

What does it do?

  • An AMQP producer sends "temperature" data to a queue
  • A Spark driver gets this data through AMQP
  • Max temperature value in the last 5 seconds is shown

Connector scenario

Temperature demo scenario

Thanks!

https://github.com/redhat-iot/amqp-spark-demo