furkanyigit34 8cbe100035 feat: PostgreSQL kuyruk sistemi (SSE yerine queue+poll) ...

Ne yaptik:
- ReportQueue modeli + Alembic migration (report_queue tablosu)
- QueueWorker: SELECT FOR UPDATE SKIP LOCKED ile tek worker polling
- 3 yeni endpoint: POST /api/queue/submit, GET /api/queue/{id}/status, GET /api/queue/active
- Startup hook ile worker otomatik basliyor, shutdown'da duruyor
- Stuck task recovery: 15 dk'dan eski PROCESSING tasklar PENDING'e donuyor

Neden yaptik:
- Esanli SSE rapor isteklerinde IP ban riski ve veri kaybi vardi
- Tek worker ile sirayla isleniyor, rate limit korunuyor
- Sifir yeni dependency: sadece PostgreSQL + mevcut scraper'lar

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

2026-04-14 16:41:19 +03:00

..

versions

feat: PostgreSQL kuyruk sistemi (SSE yerine queue+poll)

2026-04-14 16:41:19 +03:00

env.py

Initial commit: Trendyol Analiz platform

2026-01-15 00:14:38 +03:00

script.py.mako

Initial commit: Trendyol Analiz platform

2026-01-15 00:14:38 +03:00