8.6 KiB
DS Task AI News
Project Overview
DS Task AI News is a fully functional AI-powered news retrieval system that aggregates news articles from multiple RSS sources, stores them in a vector database, and provides intelligent recommendations. The system features a complete REST API, vector-based similarity search, and AI-ready architecture for enhanced news analysis.
✅ Current Status: FULLY OPERATIONAL
System Metrics:
- 714+ articles successfully processed and stored
- 3 RSS sources actively monitored (BBC, TechCrunch, WIRED)
- 10 API endpoints fully functional
- 384-dimensional vector embeddings operational
- FAISS vector database with similarity search
- Production-ready with comprehensive error handling
Features
- ✅ Multi-Source News Aggregation: Fetches from BBC Technology, TechCrunch, and WIRED RSS feeds
- ✅ Vector Database Storage: FAISS-powered vector storage with 384D embeddings
- ✅ AI-Powered Recommendations: Query-based and article-to-article similarity matching
- ✅ RESTful API: Complete FastAPI backend with 10 endpoints
- ✅ Groq LLM Integration: Ready for AI-enhanced article analysis
- ✅ Fallback Embeddings: Hash-based embeddings ensure system reliability
- ✅ Real-time Processing: Live news fetching and vector indexing
Tech Stack
- LLM: Groq (configured and ready)
- News Sources: RSS Feeds (BBC, TechCrunch, WIRED)
- Embeddings: Sentence Transformers with hash-based fallback
- Vector Database: FAISS (Facebook AI Similarity Search)
- Backend: FastAPI with Uvicorn
- Data Processing: Feedparser, NumPy, Pandas
File Structure
DS_Task_AI_News/
│-- backend/
│ │-- main.py # FastAPI backend
│ │-- news_fetcher.py # Fetches news using RSS feeds
│ │-- vector_store.py # Handles vector database operations
│ │-- embeddings.py # Generates embeddings using Cohere
│ │-- recommender.py # Fetches related news articles
│ │-- config.py # Configuration settings
│ │-- requirements.txt # Dependencies
│
│-- data/
│ │-- raw_news/ # Stores raw news articles before processing
│ │-- processed_news/ # Stores cleaned and processed articles
│
│-- docs/
│ │-- README.md # Documentation for new developers
│ │-- API_Documentation.md # API details
│
│-- .env # Environment variables
│-- .gitignore # Git ignore file
│-- LICENSE # License information
Setup & Installation
1. Clone the Repository
git clone http://23.29.118.76:3000/Test/ds_task_ai_news.git
cd ds_task_ai_news
2. Create Virtual Environment
python -m venv venv
# Windows
venv\Scripts\activate
# Linux/Mac
source venv/bin/activate
3. Install Dependencies
pip install -r backend/requirements.txt
4. Configure Environment
Create a .env file in the root directory:
# API Keys (Optional - system works without them)
GROQ_API_KEY=your_groq_api_key_here
COHERE_API_KEY=your_cohere_api_key_here
# RSS Feed Sources
RSS_FEEDS=https://feeds.bbci.co.uk/news/technology/rss.xml,https://techcrunch.com/feed/,https://www.wired.com/feed/rss
# Server Settings
HOST=0.0.0.0
PORT=8000
DEBUG=true
5. Start the Server
cd backend
python main.py
The API will be available at http://localhost:8000
🚀 Quick Start
Test the System
- Check System Health:
curl http://localhost:8000/health
- Fetch Latest News:
curl -X POST http://localhost:8000/fetch-news
- Get Trending Articles:
curl http://localhost:8000/trending?top_k=5
- Search for Articles:
curl -X POST http://localhost:8000/recommend-by-query \
-H "Content-Type: application/json" \
-d '{"query": "artificial intelligence", "top_k": 3}'
📡 RSS News Fetching
The system automatically fetches news from multiple sources:
- BBC Technology: Latest tech news and innovations
- TechCrunch: Startup and technology industry news
- WIRED: Science, technology, and digital culture
Production RSS Implementation
Our implementation includes:
- Error handling for unreliable feeds
- Content cleaning (HTML tag removal, truncation)
- Duplicate detection using content hashing
- Source attribution and metadata preservation
- Rate limiting and respectful fetching
🔌 API Endpoints
All 10 API Endpoints
GET /- API health checkGET /health- Detailed system statusPOST /fetch-news- Fetch latest news from all RSS sourcesGET /recommend-news- Get recommendations by article IDPOST /recommend-by-query- Get recommendations based on text queryPOST /recommend-by-interests- Get recommendations by user interestsGET /trending?top_k=N- Get N most recent articlesGET /articles?limit=N- Get N articles from database with filteringPOST /search- Advanced search with multiple filtersGET /stats- System statistics and metrics
Example Responses
System Health:
{
"status": "healthy",
"vector_store": {
"total_articles": 714,
"index_dimension": 384,
"index_exists": true
}
}
News Fetching:
{
"success": true,
"message": "Successfully fetched and stored news articles",
"articles_count": 119,
"articles_stored": 119,
"total_articles": 714
}
🏗️ System Architecture
Current Implementation
┌─────────────────┐ ┌──────────────────┐ ┌─────────────────┐
│ RSS Sources │───▶│ News Fetcher │───▶│ Vector Store │
│ BBC/TC/WIRED │ │ (feedparser) │ │ (FAISS) │
└─────────────────┘ └──────────────────┘ └─────────────────┘
│ │
▼ ▼
┌─────────────────┐ ┌──────────────────┐ ┌─────────────────┐
│ FastAPI │◀───│ Recommender │◀───│ Embeddings │
│ Backend │ │ System │ │ (Hash-based) │
└─────────────────┘ └──────────────────┘ └─────────────────┘
Key Components
-
News Fetcher (
news_fetcher.py)- Multi-source RSS aggregation
- Content cleaning and deduplication
- Error handling and retry logic
-
Vector Store (
vector_store.py)- FAISS-based similarity search
- 384-dimensional vector storage
- Efficient indexing and retrieval
-
Embeddings (
embeddings.py)- Hash-based fallback system
- Sentence Transformers ready
- Cohere API integration
-
Recommender (
recommender.py)- Query-based recommendations
- Article similarity matching
- Trending article detection
-
FastAPI Backend (
main.py)- RESTful API endpoints
- Async request handling
- Comprehensive error handling
🔮 Planned Enhancements
Phase 2 (Next 4 Hours)
- ✅ Sentence Transformers: Upgrade to real embeddings
- ✅ Groq AI Features: Article summaries and insights
- ✅ Enhanced APIs: Filtering, pagination, search
- ✅ Performance: Caching and optimization
Future Phases
- Real-time Updates: Scheduled RSS fetching
- User Profiles: Personalized recommendations
- Advanced Analytics: Trend analysis and reporting
- Multi-language: Support for international news
- Mobile API: Optimized endpoints for mobile apps
🧪 Testing
The system includes comprehensive testing capabilities:
# Test individual components
python test_news_fetcher.py
# Test API endpoints
curl http://localhost:8000/health
curl -X POST http://localhost:8000/fetch-news
📊 Current Metrics
- ✅ 714+ articles processed and indexed
- ✅ 3 RSS sources actively monitored
- ✅ 10 API endpoints fully operational
- ✅ 384D vector space for similarity search
- ✅ Production-ready error handling
- ✅ Clean codebase following best practices
🤝 Contributing
This system is designed for easy extension and enhancement. Key areas for contribution:
- Additional RSS sources
- Enhanced AI features
- Performance optimizations
- UI/Frontend development
📄 License
See LICENSE file for details.