Automatyzacja sprzedaży (PostgreSQL, PostgreSQL, Redis, Pydantic, Docker, curl_cffi)

Szukam programisty Python Middle/Middle+ do jednorazowej realizacji platformy opartej na zdarzeniach, z podejściem database-first i kolejkami na Redis Streams. 

Załączyłem plik .jpg z przykładem strumienia danych i przetwarzania (wersja demonstracyjna)

Zadania:
- Konfiguracja na Pydantic, zorganizowane logowanie.
- Bezpieczne przechowywanie danych wrażliwych: AES-256-GCM.
- Połączenia: PostgreSQL + Redis + MongoDB
- Warstwa sieciowa: praca przez proxy/fingerprints (warstwa klienta)
- Zrealizować usługi: Menedżer sesji, Agent sesji/Puller, Normalizacja danych, Dispatcher zdarzeń, Planowanie zadań, Telegram Gateway.
- Integracje: Pierwsza integracja (polling/HTML źródło zdarzeń) - przetłumaczyć z aiohttp na curl_cffi. Druga integracja (GraphQL + WebSocket) - gotowa. Szczegóły dotyczące endpointów/platform podam po wyborze wykonawcy.

Wymagania funkcjonalne:
1. Zarządzanie sesjami integracji
2. Odbieranie zdarzeń (Agent Puller / Transport)
3. Event Bus na Redis Streams
4. Normalizacja danych (używając opensource/moich prac)
5. Dispatcher zdarzeń (Routing)
6. Obsługiwacze/wtyczki
7. Planista zadań
8. Magazyny danych
9. Konfiguracja i zarządzanie

Wymagania niefunkcjonalne:
1. Wydajność i skalowalność
2. Niezawodność dostarczania (at-least-once)
3. Bezpieczeństwo (AES-256-GCM)
4. Efektywność zasobów (Przewidywalna degradacja)

Kryteria akceptacji:
- Repozytorium z modułową strukturą
- Działające uruchomienie przez docker-compose (postgres/redis/mongo + usługi/workerzy).
- Strumień: Surowe zdarzenie -> events:ingress -> Normalizator - > events:normalized -> Dispatcher zdarzeń -> obsługiwacze
- Planista: umieszczanie delayed-task w ZSET i przekształcanie w zdarzenie do przetworzenia.
- Dokumentacja projektu: jak uruchomić, jak dodać nowy handler/integrację, format zdarzenia (więcej szczegółów na etapie akceptacji)

Stos (oczekuję doświadczenia):
- Python 3.11+; asyncio (preferowane uvloop), background workers
- Redis Streams (grupy konsumentów), Redis ZSET (planista)
- PostgreSQL (pule połączeń), MongoDB do logów/analizy
- Pydantic, Docker/Compose
- Doświadczenie z curl_cffi Async Session (retry/timeouts/proxy) mile widziane

Format pracy:
- Jednorazowe zadanie, z możliwością długoterminowej współpracy
- Szczegóły projektu i konta testowe po rozpoczęciu współpracy
- 2 razy w tygodniu raport z wykonanej pracy. Obrazek/Wideo pod media podgrzewające.

Odpowiedź:
1. Krótko: jak zorganizowałbyś grupy konsumentów, retry, błędy, kompromisy kolejności zdarzeń (globalny vs po integration_id) (1–2 akapity).
2. Kiedy jesteś gotowy do rozpoczęcia pracy i orientacyjny czas realizacji.

W przypadku, gdy odpowiedź będzie szablonowa, pomijam.