Как создать автоматический импорт из внешнего источника с обработкой ошибок в WordPress

Автоматизация импорта данных из внешних источников — частая задача при работе с WordPress. Это может быть импорт товаров, статей, новостей или других данных из API, CSV или XML-файлов. В этой статье мы подробно разберём, как создать надёжный механизм автоматического импорта с обязательной обработкой ошибок, чтобы ваш сайт работал стабильно и не терял данные.

Почему важна обработка ошибок при импорте в WordPress

Импорт данных — это всегда риск возникновения ошибок: сбои сети, недоступность источника, некорректные данные, ошибки парсинга и т.д. Если не предусмотреть обработку таких ошибок, можно получить частично импортированные записи, дублирование, повреждение данных или полный сбой скрипта.

Обработка ошибок позволяет:

• Отлавливать и логировать проблемы для последующего анализа.
• Продолжать импорт даже при частичных сбоях.
• Уведомлять администратора сайта о критических ошибках.
• Обеспечивать целостность и актуальность данных.

Без грамотной обработки ошибок автоматизация становится ненадёжной и может привести к потере времени и ресурсов.

Подготовка к созданию автoимпорта: выбор источника и формата данных

Первым шагом нужно определить, откуда вы будете импортировать данные. Самые популярные варианты:

• REST API — часто используется для интеграции с внешними сервисами.
• CSV или XML файлы — традиционный формат обмена данными с магазинами, поставщиками и т.п.

В зависимости от источника, понадобится разный подход к получению и разбору данных. Например, для API — отправка HTTP-запросов с авторизацией, для файлов — чтение и парсинг содержимого.

Рассмотрим пример импорта из REST API с обработкой ошибок.

Реализация автоматического импорта с обработкой ошибок в WordPress

1. Создание функции импорта с логированием ошибок

Для примера создадим функцию wpkit_import_from_api(), которая загружает данные из внешнего API, парсит JSON и создаёт записи типа поста product.

function wpkit_import_from_api() {
    $api_url = 'https://api.example.com/products';
    $response = wp_remote_get($api_url, array('timeout' => 15));

    if (is_wp_error($response)) {
        error_log('WPKit Import Error: API request failed - ' . $response->get_error_message());
        return false;
    }

    $code = wp_remote_retrieve_response_code($response);
    if ($code !== 200) {
        error_log('WPKit Import Error: Unexpected response code ' . $code);
        return false;
    }

    $body = wp_remote_retrieve_body($response);
    $data = json_decode($body, true);
    if (json_last_error() !== JSON_ERROR_NONE) {
        error_log('WPKit Import Error: JSON decode error - ' . json_last_error_msg());
        return false;
    }

    if (empty($data['products']) || !is_array($data['products'])) {
        error_log('WPKit Import Error: Invalid or empty products data');
        return false;
    }

    foreach ($data['products'] as $item) {
        if (empty($item['title']) || empty($item['price'])) {
            error_log('WPKit Import Warning: Skipping product with missing title or price');
            continue;
        }

        // Проверяем, есть ли уже такой продукт по meta ключу external_id
        $existing = get_posts(array(
            'post_type' => 'product',
            'meta_key' => 'external_id',
            'meta_value' => sanitize_text_field($item['id']),
            'posts_per_page' => 1
        ));

        if ($existing) {
            // Обновляем существующий продукт
            $post_id = $existing[0]->ID;
            wp_update_post(array(
                'ID' => $post_id,
                'post_title' => sanitize_text_field($item['title']),
                'post_content' => sanitize_textarea_field($item['description'] ?? '')
            ));
        } else {
            // Создаём новый продукт
            $post_id = wp_insert_post(array(
                'post_type' => 'product',
                'post_title' => sanitize_text_field($item['title']),
                'post_content' => sanitize_textarea_field($item['description'] ?? ''),
                'post_status' => 'publish'
            ));
            if (is_wp_error($post_id)) {
                error_log('WPKit Import Error: Failed to insert product ' . $item['title']);
                continue;
            }

            update_post_meta($post_id, 'external_id', sanitize_text_field($item['id']));
        }

        update_post_meta($post_id, 'price', floatval($item['price']));
    }

    return true;
}

В этой функции мы:

• Делаем HTTP-запрос с таймаутом.
• Проверяем ошибки запроса и кода ответа.
• Декодируем JSON и проверяем корректность.
• Перебираем данные продуктов и логируем предупреждения для некорректных элементов.
• Обновляем или создаём новые посты с метаданными.
• Логируем ошибки вставки постов.

2. Настройка Cron задачи для регулярного запуска импорта

Чтобы импорт выполнялся автоматически, добавим задачу в WP-Cron:

function wpkit_schedule_import() {
    if (!wp_next_scheduled('wpkit_cron_import_hook')) {
        wp_schedule_event(time(), 'hourly', 'wpkit_cron_import_hook');
    }
}
add_action('wp', 'wpkit_schedule_import');

add_action('wpkit_cron_import_hook', 'wpkit_import_from_api');

Этот код создаёт событие, которое будет запускать импорт каждый час. При необходимости можно изменить период на twicedaily или daily, либо добавить свой интервал.

3. Уведомления администратора при ошибках

Для оперативного реагирования полезно отправлять email при критических ошибках. Добавим простой пример уведомления внутри функции импорта:

if (is_wp_error($response)) {
    $error_message = $response->get_error_message();
    error_log('WPKit Import Error: API request failed - ' . $error_message);
    wp_mail(get_option('admin_email'), 'WPKit Import Error', 'API request failed: ' . $error_message);
    return false;
}

Так можно добавить уведомления и для других ошибок — важно не создавать слишком частых писем, чтобы не спамить.

Альтернативные плагины для импорта с расширенной обработкой ошибок

Если вы не хотите писать код с нуля, можно использовать готовые решения с возможностью расширения:

• WPRemark — плагин для создания автоматических импортов с гибкими настройками и логированием.
• Clearfy Pro — имеет инструменты оптимизации и расширенного мониторинга процессов импорта.

Эти плагины позволяют настроить импорт без глубоких знаний PHP, но при необходимости можно добавлять свои хуки и фильтры для обработки ошибок.

Советы по отладке и мониторингу импорта

Для стабильной работы автоматического импорта рекомендуем:

• Использовать error_log для записи всех ошибок и предупреждений.
• Проверять логи сервера и WordPress для выявления повторяющихся проблем.
• Добавлять email-уведомления только по критическим ошибкам.
• Тестировать импорт на тестовом сайте с копией данных перед запуском на продакшене.
• Использовать транзакции или временные таблицы при сложных импортных процессах для сохранения целостности данных.

Заключение

Создание автоматического импорта с обработкой ошибок в WordPress — задача, требующая внимания к деталям и продуманности. Правильная обработка ошибок, логирование и уведомления помогут избежать потери данных и сбоев сайта. Используйте приведённый пример кода как основу для своих решений, а при необходимости расширяйте функционал с помощью популярных плагинов, таких как WPRemark и Clearfy Pro.