Pravega Sumo Flink Demo

A Demo program using Pravega, Flink to analyze data generated on Sumo

Prerequesites

1. Install Sumo 1.12.0
2. Download Pravega 0.10.1, Elasticsearch 7.6.0 and Kibana 7.6.0
3. Install python3.8, then create a virtual environment for the project.
4. Install the requirements: pip install -r requirements.txt.
5. Download Pravega connector and Elasticsearch connector jar files and copy them to the pyflink folder in your virtual environment(VIRTUAL_ENV/Lib/site-packages/pyflink/lib)

Start the demo

1. Start Pravega, Elasticsearch and Kibana
2. Set your SUMO_HOME
3. Run sumo_client.py