Интегратор - Управление интеграциями

service:
  name: "Ozon API"
  type: "marketplace"
  status: "active"

connection:
  base_url: "https://api-seller.ozon.ru"
  timeout: 30
  retry: 3

auth:
  type: "api_key"
  key_env: "OZON_API_KEY"  # Имя переменной окружения
  client_id_env: "OZON_CLIENT_ID"

endpoints:
  products: "/v2/product/list"
  orders: "/v3/posting/fbs/list"
  stocks: "/v2/products/stocks"

rate_limits:
  requests_per_second: 10
  requests_per_minute: 500

projects:
  - "marketplace"  # Какие проекты используют

documentation: "https://docs.ozon.ru/api/"

1. Прочитать: platform/integrations/{service}.yaml
2. Проверить: status=active
3. Получить: auth credentials из окружения
4. Создать: клиент API
5. Проверить: connection (test request)
6. Вернуть: клиент или ошибку

1. Получить: клиент API
2. Проверить: rate limits
3. Выполнить: запрос с retry
4. Обработать: ответ или ошибку
5. Логировать: запрос/ответ
6. Вернуть: данные

1. Прочитать: platform/integrations/mcp-servers.yaml
2. Проверить: зависимости установлены
3. Создать: конфигурацию сервера
4. Запустить: сервер
5. Проверить: доступность
6. Вернуть: статус

# Получить товары
def get_products(filter=None, limit=100):
    """
    Получить список товаров
    Endpoint: /v2/product/list
    """

# Получить заказы
def get_orders(status=None, since=None):
    """
    Получить список заказов
    Endpoint: /v3/posting/fbs/list
    """

# Обновить остатки
def update_stocks(product_id, stock):
    """
    Обновить остатки товара
    Endpoint: /v2/products/stocks
    """

# Рассчитать стоимость
def calculate_delivery(from_address, to_address, weight):
    """
    Рассчитать стоимость доставки
    """

# Создать заказ
def create_delivery_order(order_data):
    """
    Создать заказ на доставку
    """

# Отследить посылку
def track_delivery(tracking_number):
    """
    Получить статус доставки
    """

mcp_servers:
  filesystem:
    command: "npx"
    args: ["-y", "@modelcontextprotocol/server-filesystem", "$WORKSPACE"]
    status: "active"

  web_search:
    command: "npx"
    args: ["-y", "@modelcontextprotocol/server-web-search"]
    env:
      SEARCH_API_KEY: "${SEARCH_API_KEY}"
    status: "inactive"

# Проверить статус
check_mcp_server_status(name)

# Запустить сервер
start_mcp_server(name)

# Остановить сервер
stop_mcp_server(name)

# ❌ Неправильно
auth:
  api_key: "abc123xyz"

# ✅ Правильно
auth:
  api_key_env: "OZON_API_KEY"

import os

# Получить из окружения
api_key = os.getenv('OZON_API_KEY')

if not api_key:
    raise ValueError("OZON_API_KEY not found in environment")

$WORKSPACE/.env  # НЕ в git

- API доступны (статус 200)
- Credentials валидны
- Rate limits не превышены
- MCP серверы запущены
- Конфиги актуальны

Интеграции:

✅ Ozon API - активно (последний запрос: 5 мин назад)
✅ Яндекс.Доставка - активно
⚠️  СДЭК - rate limit warning (480/500)
❌ Stripe - ошибка auth (проверить STRIPE_API_KEY)

def retry_request(func, max_attempts=3):
    for attempt in range(max_attempts):
        try:
            return func()
        except RateLimitError:
            sleep(2 ** attempt)  # Exponential backoff
        except AuthError:
            break  # Не повторять
        except NetworkError:
            sleep(1)
            continue

    raise MaxRetriesExceeded()

[TIMESTAMP] [SERVICE] [METHOD] [STATUS] [DURATION]
2025-11-18 10:30:15 | Ozon | get_products | 200 | 340ms
2025-11-18 10:30:20 | Ozon | get_orders | 200 | 520ms
2025-11-18 10:30:25 | CDEK | calculate | 429 | 120ms (rate limit)

platform/logs/integrations.log

# В проекте marketplace
from platform.integrations import Integrator

integrator = Integrator()

# Получить клиент Ozon
ozon = integrator.get_client('ozon')

# Получить заказы
orders = ozon.get_orders(status='awaiting_packaging')