PowerTrade-LLM-Agent

KO | EN

gitlite — search

#javascript #python #hacktoberfest #react #ai #typescript #llm #go #golang #android #machine-learning #rust #deep-learning #linux

PowerTrade-LLM-Agent

(★ 9)

基于 ReAct Agent 与 PyTorch 时序预测的电力交易决策系统

PowerTrade-LLM-Agent Latest Version Download

Download Latest Version (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# ⚡ Electricity Price Intelligence

**Multi-Agent System for Electricity Price Forecasting & Market Intelligence**

LSTM + Chronos-T5 dual-track price prediction · Hybrid RAG (ChromaDB + BM25 + RRF) · Three Agent paradigms · Docker deployment

[![Python](https://img.shields.io/badge/Python-3.12-blue)](https://www.python.org/)
[![LangGraph](https://img.shields.io/badge/LangGraph-1.1+-green)](https://github.com/langchain-ai/langgraph)
[![PyTorch](https://img.shields.io/badge/PyTorch-CPU-red)](https://pytorch.org/)
[![Docker](https://img.shields.io/badge/Docker-Supported-2496ED)](https://www.docker.com/)

---

## Architecture

```mermaid
graph TB
    subgraph Frontend["🖥️ Frontend"]
        CL[Chainlit App]
        SL[Streamlit App]
    end

subgraph Agents["🤖 Agent Layer"]
 LG["LangGraph Agent (Dynamic + Reflection)"]
 PE["Plan-Execute Agent (Structured Planning)"]
 RA["ReAct Agent (Quick Chat)"]
 end

subgraph LLM["🧠 LLM"]
        QW[Qwen via DashScope API]
    end

subgraph Tools["🔧 Tool Layer (6 tools)"]
 WEA[get_texas_weather Open-Meteo API]
 PRED[predict_electricity_price LSTM Single-Day]
 FORC[forecast_electricity_prices LSTM Multi-Day]
 CHRO[get_chronos_prediction Chronos-T5 Cross-Validation]
 RAG[rag_summarize Hybrid RAG Search]
 FRESH[get_data_freshness Data Status Check]
 end

subgraph RAG_Engine["📚 Hybrid RAG Engine"]
 CHROMA[(ChromaDB Dense Vector)]
 BM25[BM25 Sparse Keyword]
 RRF[RRF Fusion k=60]
 KB[Knowledge Base 40 docs / 20K chunks]
 end

subgraph Models["📈 Prediction Models"]
 LSTM[LSTM Neural Network 200 epoch · Early Stopping]
 CT5[Chronos-T5 Tiny Zero-shot Forecasting]
 end

subgraph Data["📡 Data Sources"]
 MISO[MISO Real-Time LMP via GridStatus]
 CSV[Historical CSV 2024-2026 · 1400 rows]
 OM[Open-Meteo Weather API]
 end

CL --> LG
    CL --> PE
    CL --> RA
    SL --> LG
    SL --> PE
    SL --> RA

LG --> QW
    PE --> QW
    RA --> QW

QW --> WEA
    QW --> PRED
    QW --> FORC
    QW --> CHRO
    QW --> RAG
    QW --> FRESH

PRED --> LSTM
    FORC --> LSTM
    CHRO --> CT5

LSTM --> CSV
    LSTM --> MISO
    CT5 --> CSV

RAG --> CHROMA
    RAG --> BM25
    CHROMA --> RRF
    BM25 --> RRF
    RRF --> KB
```

---

## Agent Modes

| Mode | Strategy | Best For |
|------|----------|----------|
| **LangGraph Agent** | LLM autonomously decides which tools to call, with **Reflection** self-critique | Daily Q&A, single forecasts |
| **Plan-Execute Agent** | Decompose complex queries → Execute subtasks step-by-step → Synthesize report | Weekly briefings, full reports |
| **ReAct Agent** | Classic Reason-Act loop | Quick, simple queries |

### Agent Flow Comparison

subgraph PlanExecute["Plan-Execute"]
 A2[User Query] --> B2[Plan Node Decompose into subtasks]
 B2 --> C2[Execute Step 1]
 C2 --> D2[Execute Step 2]
 D2 --> E2[Execute Step N]
 E2 --> F2[Synthesize Report]
 F2 --> G2[Deliver]
 end
```

---

## Evaluation Results

### LSTM Price Prediction (30-day test, Indiana Hub)

| Metric | Univariate (price only) | **Multivariate (price+weather)** |
|--------|------------------------|----------------------------------|
| MAE | 10.31 $/MWh | **8.23 $/MWh** (-20%) |
| RMSE | 14.52 $/MWh | **12.25 $/MWh** |
| MAPE | 30.0% | **25.3%** |
| R² | -0.34 | **0.05** |
| Price Mean | 36.53 $/MWh | 36.53 $/MWh |
| Price Std | 12.56 $/MWh | 12.56 $/MWh |

*Multivariate model integrates 4 weather features (temp_max, temp_min, precipitation, wind_speed) via Open-Meteo API, achieving 20% MAE reduction over the price-only baseline.*

### Hybrid RAG Retrieval (20,857 chunks, top-3)

| Retriever | Hit Rate@3 | MRR |
|-----------|-----------|-----|
| Vector Only (ChromaDB) | 82.5% | 0.767 |
| BM25 Only | 98.75% | 0.956 |
| **Hybrid RRF** | **96.25%** | **0.877** |

---

## Tech Stack

| Layer | Technologies |
|-------|-------------|
| **Agent Framework** | LangGraph, LangChain |
| **LLM** | Qwen (DashScope API) |
| **Vector Database** | ChromaDB |
| **Sparse Retrieval** | BM25 (rank-bm25) |
| **Fusion Algorithm** | RRF (Reciprocal Rank Fusion, k=60) |
| **Deep Learning** | PyTorch, LSTM, Chronos-T5 |
| **Frontend** | Chainlit, Streamlit, Plotly |
| **Data Fetching** | GridStatus (MISO), Open-Meteo (Weather), EIA API |
| **Deployment** | Docker, docker-compose, systemd, nginx |
| **Data Processing** | Pandas, NumPy, scikit-learn |

---

## Quick Start

```bash
# 1. Clone & install
git clone <repo-url>
cd "Agent Project"
pip install -r requirements_deploy.txt
pip install torch --index-url https://download.pytorch.org/whl/cpu

# 2. Configure environment
cp .env.example .env
# Edit .env: add DASHSCOPE_API_KEY, optional EIA_API_KEY

# 3. Load knowledge base & train model
python -c "from rag.vector_store import VectorStoreService; VectorStoreService().load_document()"
python -c "from algorithms.epf_predictor import train_model; train_model()"

# 4. Launch
chainlit run chainlit_app.py --port 8000   # Chainlit (recommended)
# or
streamlit run app.py --server.port 8501   # Streamlit
```

### Docker

```bash
docker-compose up -d
# Visit http://localhost:8000
```

---

## Project Structure

```
Agent Project/
├── agent/
│   ├── langgraph_agent.py      # Dynamic agent + Reflection
│   ├── plan_execute_agent.py   # Plan-then-execute agent
│   ├── react_agent.py          # ReAct quick-chat agent
│   └── tools/
│       └── agent_tools.py      # 6 tools (weather, price, RAG, etc.)
├── algorithms/
│   ├── epf_predictor.py        # LSTM model training & inference
│   ├── price_data_provider.py  # CSV & live data interface
│   ├── gridstatus_feed.py      # MISO real-time LMP fetcher
│   └── eia_price_fetcher.py    # EIA API data fetcher
├── rag/
│   ├── vector_store.py         # Hybrid retriever (Chroma + BM25 + RRF)
│   └── rag_service.py          # RAG summarization chain
├── scripts/
│   ├── evaluate_lstm.py        # LSTM model evaluation
│   ├── evaluate_rag.py         # RAG retrieval evaluation
│   ├── update_and_retrain.py   # Auto data update + retrain
│   ├── sync_to_server.py       # Deploy to cloud server
│   └── weekly_update.bat       # Scheduled update task
├── config/
│   └── chroma.yml              # RAG & ChromaDB settings
├── data/                       # Knowledge base documents (40+ files)
├── chainlit_app.py             # Chainlit frontend
├── app.py                      # Streamlit frontend
├── Dockerfile
├── docker-compose.yml
└── requirements_deploy.txt
```

---

## Key Innovations

1. **Three Agent Paradigms**: LangGraph dynamic agent with Reflection, Plan-Execute structured planning, and ReAct — all switchable at runtime for head-to-head comparison.

2. **Self-Correcting Agent**: Reflection node critiques its own responses for factual accuracy, completeness, and clarity, then auto-revises before delivery.

3. **Hybrid RAG with RRF**: Custom implementation combining ChromaDB dense vectors and BM25 sparse retrieval via Reciprocal Rank Fusion (k=60), achieving 96%+ hit rate on 20K+ chunks.

4. **Dual-Track Price Forecasting**: LSTM neural network (200-epoch training with early stopping) paired with Chronos-T5 zero-shot model for cross-validation.

5. **Production-Ready**: Docker containerization with docker-compose, systemd service management, nginx reverse proxy, and automated data pipeline.

PowerTrade-LLM-Agent

PowerTrade-LLM-Agent Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

PowerTrade-LLM-Agent

PowerTrade-LLM-Agent Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Download README