db processing to stream