insightedge-python-demo

Python API demo: real time flights delay prediction

Running demo

Before running the demo you need to install Maven, Sbt, Kafka and Numpy.

1. Get into demo folder cd path/to/insightedge-python-demo

2. Set INSIGHTEDGE_HOME and KAFKA_HOME env vars

   export INSIGHTEDGE_HOME="path/to/insightedge"
   export KAFKA_HOME="path/to/kafka"

3. Install InsightEdge into maven repo $INSIGHTEDGE_HOME/sbin/insightedge-maven.sh

4. Launch InsightEdge $INSIGHTEDGE_HOME/sbin/insightedge.sh --mode demo

5. Launch Kafka with ./scripts/kafka-start.sh

6. Submit model training job ./scripts/spark-model-training-job.sh

7. Submit flight delay prediction job ./scripts/spark-flight-delay-prediction-job.sh. Please note that this is endless job.

8. In separate terminal tab submit data to Kafka topic ./scripts/kafka-submit-data.sh. In the console you will see rows which were sent to the Kafka topic.

9. Run web application sbt web/run

10. Investigate results

• in Zeppelin(http://127.0.0.1:8090), import a notebook from zeppelin folder

• in web app(http://localhost:9000)

• To shutdown InsightEdge run $INSIGHTEDGE_HOME/sbin/insightedge.sh --mode shutdown

• To shutdown Kafka run ./scripts/kafka-stop.sh

• To stop prediction Spark job ./scripts/spark-stop-prediction-job.sh