Оптимизация рекламы в Яндекс.Директ только на целевые лиды без CRM: Пишем свой коннектор на Python и GAS

Тип: JavaScript-событие. Идентификатор цели: lead_approved ❗️ Важно: Убедитесь, что тип совпадения выбран "Совпадает".

pip install requests gspread

[ { "client_name": "Proekt_A", "counter_id": "ВАШ_ID_СЧЕТЧИКА", "goal_ids": [ "ID_ЦЕЛИ_1", "ID_ЦЕЛИ_2" ] } ]

import json import requests import gspread from datetime import date, timedelta, datetime # --- 1. ГЛОБАЛЬНЫЕ НАСТРОЙКИ --- METRIKA_TOKEN = "ВСТАВЬТЕ_СЮДА_ВАШ_ТОКЕН" CONFIG_FILE = 'client_goal.json' GOOGLE_CREDENTIALS_FILE = 'google_credentials.json' SPREADSHEET_NAME = "ВСТАВЬТЕ_СЮДА_НАЗВАНИЕ_ВАШЕЙ_ТАБЛИЦЫ" # ------------------------------------ # --- НОВОЕ: Заголовки для новой таблицы --- SHEET_HEADERS = [ 'timestamp', 'client_name', 'counter_id', 'clientID', 'utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'status', 'upload_id' ] # ------------------------------------------- def get_metrika_reports(counter_id, goal_ids, date1, date2, client_name): # <-- Добавлен client_name для логгирования """ Запрашивает у Reports API Метрики визиты с нужными целями за указанный период. """ # Теперь client_name передается в функцию напрямую print(f"- Обрабатываю '{client_name}' (счетчик {counter_id})...") api_url = "https://api-metrika.yandex.net/stat/v1/data" headers = {'Authorization': f'OAuth {METRIKA_TOKEN}'} goal_filters = [f"ym:s:goal{goal_id}IsReached=='Yes'" for goal_id in goal_ids] filters_string = " OR ".join(goal_filters) params = { "ids": counter_id, "metrics": "ym:s:visits", "dimensions": "ym:s:dateTime,ym:s:clientID,ym:s:UTMSource,ym:s:UTMMedium,ym:s:UTMCampaign,ym:s:UTMTerm", "date1": date1, "date2": date2, "filters": filters_string, "accuracy": "full", "limit": 100000 } try: response = requests.get(api_url, headers=headers, params=params) response.raise_for_status() response_json = response.json() data = response_json.get('data', []) if not data: print(" Лиды за этот период не найдены.") return [] visits = [] for item in data: dims = item['dimensions'] visits.append({ 'date': dims[0]['name'], 'clientID': dims[1]['name'], 'utm_source': dims[2]['name'], 'utm_medium': dims[3]['name'], 'utm_campaign': dims[4]['name'], 'utm_term': dims[5]['name'], }) print(f" Найдено лидов: {len(visits)}") return visits except requests.exceptions.RequestException as e: print(f" ! Ошибка при запросе к Reports API: {e}") try: print(" Ответ сервера:", e.response.json()) except: pass return [] # --- ИЗМЕНЕНА ФУНКЦИЯ --- def update_google_sheet(leads, client_name): """ Обновляет Google Таблицу. Находит лист по client_name или создает новый, если лист не найден, и добавляет в него данные. """ if not leads: print("\nНет новых лидов для добавления в таблицу.") return print(f"\nПодключаюсь к Google Таблице '{SPREADSHEET_NAME}'...") try: gc = gspread.service_account(filename=GOOGLE_CREDENTIALS_FILE) spreadsheet = gc.open(SPREADSHEET_NAME) # --- НОВАЯ ЛОГИКА: Поиск или создание вкладки (листа) --- try: worksheet = spreadsheet.worksheet(client_name) print(f"Найден лист (вкладка) с именем '{client_name}'. Добавляю данные...") except gspread.exceptions.WorksheetNotFound: print(f"Лист с именем '{client_name}' не найден. Создаю новый...") # Создаем новый лист и добавляем в него заголовки worksheet = spreadsheet.add_worksheet(title=client_name, rows=1, cols=len(SHEET_HEADERS)) worksheet.append_row(SHEET_HEADERS) print(f"Лист '{client_name}' успешно создан.") # -------------------------------------------------------- rows_to_add = [] for lead in leads: # Порядок данных должен строго соответствовать заголовкам SHEET_HEADERS rows_to_add.append([ lead['date'], lead['client_name'], lead['counter_id'], lead['clientID'], lead['utm_source'], lead['utm_medium'], lead['utm_campaign'], lead['utm_term'], 'new' # status ]) if rows_to_add: worksheet.append_rows(rows_to_add, value_input_option='USER_ENTERED') print(f"Успешно добавлено {len(rows_to_add)} строк в лист '{client_name}'.") else: print("Нет строк для добавления.") except Exception as e: print(f" ! Ошибка при работе с Google Таблицей: {e}") def get_date_from_user(prompt): """Запрашивает у пользователя дату и проверяет ее корректность.""" while True: date_str = input(prompt) try: datetime.strptime(date_str, '%Y-%m-%d') return date_str except ValueError: print("Неверный формат. Пожалуйста, введите дату в формате ГГГГ-ММ-ДД (например, 2025-11-20)") # --- ИЗМЕНЕН ГЛАВНЫЙ БЛОК --- if __name__ == "__main__": try: with open(CONFIG_FILE, 'r', encoding='utf-8') as f: client_configs = json.load(f) except FileNotFoundError: print(f"Ошибка: Файл конфигурации '{CONFIG_FILE}' не найден.") exit() # --- НОВАЯ ЛОГИКА: Выбор клиента --- client_names = [config.get("client_name") for config in client_configs if config.get("client_name")] if not client_names: print("В файле конфигурации не найдено ни одного клиента.") exit() print("--- Выбор клиента для выгрузки ---") print("Доступные клиенты:", ", ".join(client_names)) selected_client_name = None selected_config = None while not selected_config: user_input = input("Введите имя клиента, для которого хотите сделать выгрузку: ") # Ищем конфиг для введенного клиента for config in client_configs: if config.get("client_name", "").lower() == user_input.lower(): selected_config = config selected_client_name = config.get("client_name") break if not selected_config: print(f"Клиент с именем '{user_input}' не найден. Попробуйте еще раз.") print(f"\nВыбран клиент: '{selected_client_name}'.") # --------------------------------------------- # --- БЛОК ЗАПРОСА ДАТ: остался без изменений --- print("\n--- Настройка периода выгрузки ---") date_start = get_date_from_user("Введите дату начала (ГГГГ-ММ-ДД): ") date_end = get_date_from_user("Введите дату конца (ГГГГ-ММ-ДД): ") print(f"Выбран период с {date_start} по {date_end}.\n") # ---------------------------------------------------- all_leads_to_upload = [] print("--- Начинаю сбор лидов ---") # Теперь работаем только с выбранной конфигурацией, а не в цикле counter_id = selected_config.get("counter_id") goal_ids = selected_config.get("goal_ids") if counter_id and goal_ids: # Передаем даты и имя клиента в функцию сбора данных leads_from_metrika = get_metrika_reports(counter_id, goal_ids, date_start, date_end, selected_client_name) for lead in leads_from_metrika: lead['client_name'] = selected_client_name lead['counter_id'] = counter_id all_leads_to_upload.append(lead) # Передаем лиды и имя клиента в функцию обновления таблицы update_google_sheet(all_leads_to_upload, selected_client_name) else: print(f"В конфигурации для '{selected_client_name}' отсутствуют counter_id или goal_ids.") print("\nРабота скрипта завершена.")

venv\Scripts\activate

source venv/bin/activate

python main.py

// --- НАСТРОЙКИ --- const AUTH_TOKEN = "ВАШ_AOUTH_TOKEN"; // <-- ВАШ ПОЛНЫЙ OAuth ТОКЕН const TRIGGER_STATUS = "da"; // <-- СИМВОЛ-ТРИГГЕР // --------------------------------------------------- // --- НОМЕРА СТОЛБЦОВ --- // A=1, B=2, C=3 (counter_id), D=4, E=5, F=6 (clientID), ... K=11 (status), L=12 (upload_id) const COUNTER_ID_COLUMN = 3; // Столбец C (counter_id) const CLIENT_ID_COLUMN = 4; // Столбец F (clientID) const STATUS_COLUMN = 9; // Столбец K (status) const UPLOAD_ID_COLUMN = 10; // Столбец L (upload_id) const GOAL_ID = "lead_approved"; // --- НАСТРОЙКИ ДЛЯ ПРОВЕРКИ СТАТУСА --- const STATUS_SENT = "Отправлено"; const STATUS_SUCCESS = "Успешно"; const STATUS_ERROR = "Ошибка"; const COLOR_SUCCESS = "#d9ead3"; // Светло-зеленый const COLOR_ERROR = "#f4cccc"; // Светло-красный const COLOR_NEUTRAL = "#ffffff"; // Белый (для сброса) // ---------------------------------------------------- /** * ======================================================================================= * === БЛОК 1: ФУНКЦИИ ОТПРАВКИ КОНВЕРСИЙ (СРАБАТЫВАЮТ ПРИ РЕДАКТИРОВАНИИ) === * ======================================================================================= */ function processEdit(e) { Logger.log("--- Запуск скрипта отправки конверсии ---"); // --- ИСПРАВЛЕНИЕ: Возвращаем getActiveRange(), чтобы работало и при ручном запуске --- const range = SpreadsheetApp.getActiveRange(); const sheet = range.getSheet(); const newValue = range.getValue().toString() || ""; // Условие срабатывания остается прежним: редактирование нужного столбца if (range.getColumn() === STATUS_COLUMN) { if (newValue.trim().toLowerCase() === TRIGGER_STATUS) { const row = range.getRow(); // Пропускаем заголовок if (row === 1) return; const counterID = sheet.getRange(row, COUNTER_ID_COLUMN).getValue(); const clientID = sheet.getRange(row, CLIENT_ID_COLUMN).getValue(); if (clientID && counterID) { Logger.log(`Лист: "${sheet.getName()}", Строка: ${row}. Статус изменен на '${TRIGGER_STATUS}'. ClientID: ${clientID}, CounterID: ${counterID}. Запускаю отправку.`); sendConversionToMetrika(clientID, counterID, sheet, row); } else { Logger.log(`Лист: "${sheet.getName()}", Строка: ${row}. Статус изменен, но ClientID или CounterID пустой. Отправка отменена.`); } } } } /** * Отправляет данные о конверсии в API Яндекс.Метрики в формате CSV. * Эта функция остается БЕЗ ИЗМЕНЕНИЙ, она универсальна. * @param {string} clientID Идентификатор клиента для отправки. * @param {string} counterID Идентификатор счетчика, куда отправлять конверсию. * @param {GoogleAppsScript.Spreadsheet.Sheet} [sheet] - Активный лист * @param {number} [row] - Номер текущей строки */ function sendConversionToMetrika(clientID, counterID, sheet, row) { const url = `https://api-metrika.yandex.ru/management/v1/counter/${counterID}/offline_conversions/upload?client_id_type=CLIENT_ID`; const cleanedClientID = clientID.toString().trim(); const boundary = "------------------------" + Math.random().toString(36).substring(2); const timestamp = Math.floor(new Date().getTime() / 1000); const fileContent = `ClientId,Target,DateTime\n${cleanedClientID},${GOAL_ID},${timestamp}`; const payload = "--" + boundary + "\r\n" + "Content-Disposition: form-data; name=\"file\"; filename=\"data.csv\"\r\n" + "Content-Type: text/csv\r\n\r\n" + fileContent + "\r\n" + "--" + boundary + "--"; const options = { 'method': 'POST', 'contentType': 'multipart/form-data; boundary=' + boundary, 'headers': { 'Authorization': `OAuth ${AUTH_TOKEN}` }, 'payload': Utilities.newBlob(payload).getBytes(), 'muteHttpExceptions': true }; try { const response = UrlFetchApp.fetch(url, options); const responseCode = response.getResponseCode(); const responseBody = response.getContentText(); if (responseCode === 200) { const jsonResponse = JSON.parse(responseBody); const uploadId = jsonResponse.uploading.id; Logger.log(`✅ УСПЕХ! Данные для ClientID ${cleanedClientID} отправлены. Получен Upload ID: ${uploadId}`); if (sheet && row) { sheet.getRange(row, STATUS_COLUMN).setValue(STATUS_SENT); sheet.getRange(row, UPLOAD_ID_COLUMN).setValue(uploadId); sheet.getRange(row, STATUS_COLUMN).setBackground(COLOR_NEUTRAL); } } else { Logger.log(`Ошибка отправки в счетчик ${counterID}. Код: ${responseCode}. Ответ: ${responseBody}`); if (sheet && row) { sheet.getRange(row, STATUS_COLUMN).setValue(STATUS_ERROR).setBackground(COLOR_ERROR); } } } catch (error) { Logger.log('Критическая ошибка: ' + error.toString()); if (sheet && row) { sheet.getRange(row, STATUS_COLUMN).setValue(STATUS_ERROR).setBackground(COLOR_ERROR); } } } /** * =============================================================================== * === БЛОК 2: ФУНКЦИИ ДЛЯ ПРОВЕРКИ СТАТУСА (ЗАПУСКАЮТСЯ ПО ТРИГГЕРУ) === * =============================================================================== */ /** * Главная функция, которую нужно будет запускать по триггеру (например, раз в час). * --- ИЗМЕНЕНИЕ: Теперь она проходит по всем листам в таблице. --- */ function checkConversionStatuses() { Logger.log("--- Запуск проверки статусов офлайн-конверсий по всем листам ---"); // Получаем все листы (вкладки) в текущей таблице const allSheets = SpreadsheetApp.getActiveSpreadsheet().getSheets(); // Проходим циклом по каждому листу for (const sheet of allSheets) { Logger.log(`\n>>> Обрабатываю лист: "${sheet.getName()}"`); // Пропускаем пустые листы или листы только с заголовком if (sheet.getLastRow() < 2) { Logger.log("Лист пустой, пропускаю."); continue; } const dataRange = sheet.getRange(2, 1, sheet.getLastRow() - 1, sheet.getLastColumn()); const values = dataRange.getValues(); let foundToCheck = 0; // Счетчик для логов for (let i = 0; i < values.length; i++) { const row = i + 2; const status = values[i][STATUS_COLUMN - 1]; const uploadId = values[i][UPLOAD_ID_COLUMN - 1]; const counterId = values[i][COUNTER_ID_COLUMN - 1]; if (status === STATUS_SENT && uploadId && counterId) { foundToCheck++; Logger.log(` Проверяю строку ${row}: CounterID=${counterId}, UploadID=${uploadId}`); const statusResponse = getMetrikaUploadStatus(counterId, uploadId); if (statusResponse) { const metrikaStatus = statusResponse.uploading.status; const statusCell = sheet.getRange(row, STATUS_COLUMN); Logger.log(` Статус от Метрики: ${metrikaStatus}`); if (metrikaStatus === "PROCESSED") { statusCell.setValue(STATUS_SUCCESS).setBackground(COLOR_SUCCESS); Logger.log(` ✅ Строка ${row} успешно обработана.`); } else if (metrikaStatus === "FAILED") { const errorMessage = statusResponse.uploading.comment || "Нет деталей"; statusCell.setValue(STATUS_ERROR).setBackground(COLOR_ERROR); statusCell.setComment(`Ошибка от API: ${errorMessage}`); Logger.log(` ❌ Ошибка в строке ${row}. Комментарий: ${errorMessage}`); } } } } if (foundToCheck === 0) { Logger.log("На этом листе не найдено строк со статусом 'Отправлено'."); } } Logger.log("\n--- Проверка статусов завершена ---"); } /** * Запрашивает у API Метрики статус загрузки по ее ID. * Эта функция остается БЕЗ ИЗМЕНЕНИЙ, она универсальна. * @param {string} counterId Идентификатор счетчика. * @param {string} uploadId Идентификатор загрузки. * @returns {object|null} Объект ответа API или null в случае ошибки. */ function getMetrikaUploadStatus(counterId, uploadId) { const url = `https://api-metrika.yandex.ru/management/v1/counter/${counterId}/offline_conversions/uploading/${uploadId}`; const options = { 'method': 'GET', 'headers': { 'Authorization': `OAuth ${AUTH_TOKEN}` }, 'muteHttpExceptions': true }; try { const response = UrlFetchApp.fetch(url, options); if (response.getResponseCode() === 200) { return JSON.parse(response.getContentText()); } else { Logger.log(` ! Ошибка при запросе статуса для UploadID ${uploadId}. Код: ${response.getResponseCode()}, Ответ: ${response.getContentText()}`); return null; } } catch (error) { Logger.log(` ! Критическая ошибка при запросе статуса: ${error.toString()}`); return null; } }