Radhika489

21
reputation
3

I am new learner of deep learning and artificial intelligence. Currently, I am doing my own project using Kafka streaming. Project Name: Detecting deviation in demand of Electricity Power(V*I) using Apache Spark and Kafka. This project was aim to find sudden spike in demand for electricity power. Set of IoT devices who measures Current and Voltage in different power meters and fed that in streaming data with every 15 minute. After every 15 minutes power value from each power meter in locality is streamed through Kafka. We created new performance indicator by feeding KAFKA streaming data(json format) to Spark based processing system(structured streaming is used) in which the standard deviation of the input value (by considering last 36 values of the power) is computed and it will be compared to the current value of power. Final performance indicator is made in streaming format and fed into KAFKA. If the difference of current value with last 40 stddev is positive then output will be 1 else it would be 0.