Create Simple Real-time Data Pipelines