ИИ-агент аудирует Яндекс.Директ: как находить деньги которые ты теряешь каждую неделю

import requests
import anthropic
import json
from datetime import datetime, timedelta

DIRECT_TOKEN = "YOUR_DIRECT_TOKEN"   # OAuth-токен Яндекс.Директ
CLAUDE_API_KEY = "YOUR_CLAUDE_KEY"   # ключ Anthropic API
TELEGRAM_TOKEN = "YOUR_BOT_TOKEN"   # токен бота @BotFather
CHAT_ID = "YOUR_CHAT_ID"            # ID чата для отчёта

DIRECT_URL = "https://api.direct.yandex.com/json/v5/"
HEADERS = {
  "Authorization": f"Bearer {DIRECT_TOKEN}",
  "Accept-Language": "ru",
}

def get_campaigns():
  """Получаем все активные кампании."""
  payload = {
      "method": "get",
      "params": {
          "SelectionCriteria": {"States": ["ON", "SUSPENDED"]},
          "FieldNames": [
              "Id", "Name", "Status", "State",
              "DailyBudget", "NegativeKeywords"
          ],
      }
  }
  r = requests.post(DIRECT_URL + "campaigns", headers=HEADERS, json=payload)
  r.raise_for_status()
  return r.json().get("result", {}).get("Campaigns", [])

def get_stats_report():
  """Статистика по ключам за последние 30 дней через Reports API."""
  date_to = datetime.now().strftime("%Y-%m-%d")
  date_from = (datetime.now() - timedelta(days=30)).strftime("%Y-%m-%d")

  payload = {
      "params": {
          "SelectionCriteria": {"DateFrom": date_from, "DateTo": date_to},
          "Goals": [],
          "AttributionModels": ["LC"],
          "FieldNames": [
              "CampaignName", "CampaignId", "Keyword",
              "Cost", "Clicks", "Impressions", "Conversions", "Ctr"
          ],
          "ReportName": f"weekly_audit_{date_from}",
          "ReportType": "KEYWORD_PERFORMANCE_REPORT",
          "DateRangeType": "CUSTOM_DATE",
          "Format": "JSON",
          "IncludeVAT": "YES",
          "IncludeDiscount": "NO"
      }
  }
  # Reports API может вернуть 201 — отчёт строится, нужно повторить
  r = requests.post(DIRECT_URL + "reports", headers=HEADERS, json=payload)
  if r.status_code == 201:
      import time; time.sleep(5)
      r = requests.post(DIRECT_URL + "reports", headers=HEADERS, json=payload)
  r.raise_for_status()
  return r.json()

def analyze_with_claude(campaigns, stats):
  """Отправляем данные в Claude, получаем отчёт."""
  client = anthropic.Anthropic(api_key=CLAUDE_API_KEY)

  # Находим проблемы самостоятельно для ускорения
  no_minus = [c["Name"] for c in campaigns if not c.get("NegativeKeywords")]
  zero_conv = []
  for kw in stats.get("data", []):
      cost = float(kw.get("Cost", 0))
      convs = int(kw.get("Conversions", 0))
      if cost > 500 and convs == 0:
          zero_conv.append({
              "campaign": kw["CampaignName"],
              "keyword": kw["Keyword"],
              "cost_rub": round(cost / 1_000_000, 2)  # Директ хранит в микрорублях
          })

  prompt = f"""Ты помощник по анализу Яндекс.Директ. Составь еженедельный отчёт.

Данные аудита за последние 30 дней:

1. КАМПАНИИ БЕЗ МИНУС-СЛОВ ({len(no_minus)} шт.):
{json.dumps(no_minus, ensure_ascii=False, indent=2)}

2. КЛЮЧИ С РАСХОДОМ БЕЗ КОНВЕРСИЙ (расход > 500 ₽):
{json.dumps(zero_conv[:20], ensure_ascii=False, indent=2)}

Общее число кампаний: {len(campaigns)}
Ключей с нулевой конверсией: {len(zero_conv)}
Суммарный расход на «пустые» ключи: {sum(k['cost_rub'] for k in zero_conv):.0f} ₽

Напиши отчёт в формате:
- Кратко: 2-3 предложения о состоянии аккаунта
- Топ-3 проблемы с конкретными суммами
- 3 действия на эту неделю (конкретные, с названиями кампаний)

Пиши по-русски, кратко и по делу."""

  message = client.messages.create(
      model="claude-sonnet-4-6",
      max_tokens=1024,
      messages=[{"role": "user", "content": prompt}]
  )
  return message.content[0].text

def send_telegram(text):
  """Отправляем отчёт в Telegram."""
  requests.post(
      f"https://api.telegram.org/bot{TELEGRAM_TOKEN}/sendMessage",
      json={
          "chat_id": CHAT_ID,
          "text": f"📊 <b>Еженедельный аудит Директа</b>\n\n{text}",
          "parse_mode": "HTML"
      }
  )

if __name__ == "__main__":
  print("Собираем данные...")
  campaigns = get_campaigns()
  stats = get_stats_report()

  print(f"Кампаний: {len(campaigns)}, анализируем...")
  report = analyze_with_claude(campaigns, stats)

  send_telegram(report)
  print("Отчёт отправлен в Telegram.")