A Python stream processing engine modeled after Yahoo! Pipes