Skip to content

Latest commit

 

History

History
18 lines (12 loc) · 1.23 KB

README.md

File metadata and controls

18 lines (12 loc) · 1.23 KB

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