ai-engine

Task-queue микросервис для поиска недвижимости и генерации писем. Клиент отправляет запрос, получает

Установка и запуск

Конфигурация

Все переменные читаются из

База данных

При отсутствии Postgres-переменных — фолбэк на

LLM

При отсутствии API-ключа сервис стартует с предупреждением — агент недоступен, используется deterministic executor.

Парсер и роутинг

API

GET /health

POST /v1/send_message

Поиск объявлений.

Ответ:

POST /v1/write_mail

Генерация письма по объявлению.

GET /v1/result/{task_uuid}

Опрос результата задачи.

GET /v1/tasks

Список всех задач. Query param:

GET /v1/tasks/{task_uuid}

Статус конкретной задачи.

Поток выполнения

POST /v1/send_message или /v1/write_mail
  → TaskService.create_task()  →  RuntimeTask (IN_PROGRESS)
  → BackgroundTasks.add_task() →  возвращает task_id сразу

Фон (таймаут 60s):
  TaskExecutionPolicy → "agent" | "deterministic"
  agent: run_agent() via LangGraph
    ├─ загружает Premises + Messages сессии из БД
    ├─ инструменты: find_listings_tool, change_objects_tool
    └─ при AgentExecutionError → fallback на deterministic
  TaskService.save() → COMPLETED | ERROR

GET /v1/result/{task_uuid} → ResultResponse

Тесты

Demo-скрипт