Streamparse lets you run Python code against real-time streams of data via Apache Storm.
https://github.com/pystorm/streamparse.git