EcoStreamDispatch

Built with:
• @pathway_com (streaming engine + DocStore)
• @FastAPI backend
• @reactjs+ Tailwind frontend
• @Docker Compose for reproducible local runs
alpha

[EcoStreamDispatch @EcoStreamD]

EcoStream Dispatch — A real-time fleet intelligence platform for climate-aware logistics. It ingests live telemetry, runs sliding-window analytics, detects anomalies (e.g. motor overheat), and surfaces actionable diagnostics.

#FleetManagement #Pathway #StreamingData #DocStore

[EcoStreamDispatch @EcoStreamD]

In EcoStream Dispatch, Pathway RAG powers the diagnostics flow — pulling exact troubleshooting steps from Tata/Mahindra manuals. If RAG is down, it gracefully falls back to DocumentStore.

#RAG #Pathway #FleetTech

[EcoStreamDispatch @EcoStreamD]

What is RAG and how does it work? 🧵

RAG = Retrieval-Augmented Generation.

It works in two steps:
1. Retrieve the most relevant documents (service manuals, PDFs, etc.)
2. Feed those docs + the user query to an LLM

Result: accurate, grounded answers instead of hallucinations.

[EcoStreamDispatch @EcoStreamD]

10/10 What this means for climate impact:

The system is designed to reduce preventable operational waste by detecting high-risk behavior earlier and supporting better dispatch & maintenance timing.

Next step: beta hardening with stronger observability and scale validation.
#RAG

[EcoStreamDispatch @EcoStreamD]

We built EcoStream Dispatch as an alpha real-time fleet intelligence system for climate-aware logistics.

It’s not publicly launched yet, but the architecture is already split like a real product: frontend, API, pipeline worker, docstore, and optional RAG service. #Pathway

[EcoStreamDispatch @EcoStreamD]

9/10 Docker is central to this alpha workflow.

One `docker compose up` runs the full stack reproducibly for demos and team onboarding: frontend, API, pipeline, docstore, and optional RAG.

Realistic end-to-end environment from day one.

[EcoStreamDispatch @EcoStreamD]

3/3 Runs fully on Docker Compose:

- React frontend (8080)
- FastAPI backend (8780)
- Pathway pipeline
- DocumentStore + optional RAG

One `docker compose up` starts everything cleanly. Great for local alpha demos & development.

#Docker #Pathway

[EcoStreamDispatch @EcoStreamD]

Thread:EcoStream Dispatch real-time telemetry with Pathway 🧵

1/ Supports sim, demo & Kafka sources.
2/ 60s sliding window per unit → avg/max temp, speed & SOC.
3/ Overheat alert >85°C (High >90°C).
4/ Diagnostics: RAG → DocumentStore fallback.

Alpha stage. Feedback? #Pathway

[EcoStreamDispatch @EcoStreamD]

2/3 Frontend built with React + Vite + Tailwind.

• Live dashboard with telemetry cards & anomaly alerts
• Fleet table with status & real-time data
• Alert queue with one-click diagnostics
• Clean dark ops-focused UI

Still iterating. Thoughts? #React #Vite #Tailwind