Автоматизация продаж (PostgreSQL, PostgreSQL, Redis, Pydantic, Docker, curl_cffi)

Ищу Python Middle/Middle+ разработчика на разовую реализацию event-driven платформы, с database-first подходом и очередями на Redis Streams. 

Прикрепил  .jpg файл с примером потока данных и обработки (демоверсия)

Задачи:
- Конфиг на Pydantic, структурированное логирование.
- Безопасное хранение чувствительных данных: AES-256-GCM.
- Подключения: PostgreSQL + Redis + MongoDB
- Сетевой слой: работа через прокси/фингерпринты (клиентский слой)
- Реализовать сервисы: Менеджер сессий, Агент сессии/Puller, Нормализация данных, Диспетчер событий, Планирование задач, Telegram Gateway.
- Интеграции: Первая интеграция (polling/HTML источник событий) - перевести с aiohttp на curl_cffi. Вторая интеграция(GraphQL + WebSocket) - готовая. Конкретику эндпоинтов/платформ даю после выбора исполнителя.

Функциональные требования:
1. Управление сессиями интеграций
2. Приём событий (Agent Puller / Transport)
3. Event Bus на Redis Streams
4. Нормализация данных(используя opensource/мои наработки)
5. Диспетчер событий (Маршрутизация )
6. Обработчики/плагины
7. Планировщик задач
8. Хранилища данных
9. Конфигурация и управление

Нефункциональные требования:
1. Производительность и масштабирование
2. Надёжность доставки (at-least-once)
3. Безопасность (AES-256-GCM)
4. Ресурсоэффективность (Предсказуемая деградация)

Критерии приёмки:
- Репозиторий с модульной структурой
- Рабочий запуск через docker-compose (postgres/redis/mongo + сервисы/воркеры).
- Поток: Сырое событие -> events:ingress -> Нормализатор - > events:normalized -> Диспетчер событий -> handlers
- Планировщик: постановка delayed-task в ZSET и преобразование в событие для обработки.
- Документация к проекту: как поднять, как добавить новый handler/интеграцию, формат события (более подробнее на этапе приёмки)

Стек(ожидаю опыт):
- Python 3.11+; asyncio (желательно uvloop), фоновые воркеры
- Redis Streams (consumer groups), Redis ZSET (scheduler)
- PostgreSQL (пулы соединений), MongoDB для логов/аналитики
- Pydantic, Docker/Compose
- Опыт с curl_cffi Async Session (ретраи/таймауты/прокси) приветствуется

Формат работы:
- Разовая задача, с возможным долгосрочным сотрудничеством
- Детали проекта и тестовые аккаунты, после начала сотрудничества
- 2 раза в неделю отчет о проделанной работе. Картинка\Видео под медиа прогрев.

Отклик:
1. Коротко: как вы бы организовали consumer groups, ретраи, ошибки, компромиссы порядка событий(глобальный vs по integration_id) (1–2 абзаца).
2. Когда готовы начина работу и ориентир по сроку выполнения.

В случае если отклик будет шаблонный, пропуск.