python-pipeline lets you create pipelines of iterators.

Example:

>>> from pipeline import *
>>> xrange(-10, 10) | grep(lambda x: x % 3 == 2) | (x * (x + 1) for x in STDIN) | list
[90, 42, 12, 0, 6, 30, 72]