unix-pipeline-like stream processing in python