How would you design an architecture to ingest and process sensor data from agricultural equipment in near real-time?