I probably could use map/reduce, then have the results placed on a message bus to be picked up later by another external process.