Real-time data pipeline for equipment failure prediction