End-to-end data pipeline analyzing Ethiopian medical Telegram channels. Includes data scraping, warehouse modeling with dbt, image detection (YOLOv8), and FastAPI analytics. Built with Docker, PostgreSQL, and Dagster orchestration."
# π₯ ETHIO-MED-TELEGRAM-ANALYTICS
**Containerized analytics platform** for Ethiopian medical Telegram data π¦πͺπΉ
End-to-end pipeline for NLP/CV tasks: Named Entity Recognition (NER) & YOLOv8 image detection
---
## π§ Project Overview
Robust **ELT pipeline** ingesting Amharic Telegram messages from Ethiopian medical channels. Processes data for:
- π§ Amharic NER (Named Entity Recognition)
- ποΈ YOLOv8 medical object detection
- π Business analytics API
---
## π§ Tech Stack
| Layer | Tool |
|-------------------|-------------------------------|
| π **Database** | PostgreSQL 14 + pgAdmin |
| π§± **Transform** | dbt (Data Build Tool) |
| π€ **Ingestion** | Telethon + Custom Python |
| π **API** | FastAPI + Pydantic |
| π€ **ML Models** | YOLOv8, HuggingFace Transformers |
| βοΈ **Orchestration** | Dagster |
| π³ **Infra** | Docker + Docker Compose |
---
## π Directory Structure
βββ data/ # Telegram data
β βββ raw/ # Raw JSONs
β βββ preprocessed/ # Cleaned data
βββ ethio_api/ # FastAPI app
βββ ethio_pipeline/ # Dagster jobs
βββ telegram_dbt_project/ # dbt models
βββ scripts/ # Data scripts
βββ notebooks/ # EDA/ML experiments
βββ .env # Environment secrets
βββ docker-compose.yml # Multi-container setup
βββ requirements.txt # Dependencies
βββ README.md
## π Quickstart Guide
### 1. Clone & Configure
```bash
git clone
github.com
cd ETHIO-MED-TELEGRAM-ANALYTICS
cp .env.example .env
π Edit .env with PostgreSQL and Telegram credentials
2. Launch Containers
docker compose up --build
3. Scrape Messages
python scripts/scrape_telegram.py --channel @cheMed123 --limit 1000
4. Load Raw Data
python scripts/load_raw_json.py --input data/raw/telegram_messages/YYYY-MM-DD/
5. Run dBT Transformations
docker exec -w /app/telegram_dbt_project -it telegram_app dbt build
6. Serve Documentation (Optional)
docker exec -w /app/te β¦