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

В современных проектах на WordPress часто возникает задача автоматического импорта данных из внешних API. Это может быть импорт товаров, новостей, событий или любых других данных, которые обновляются на стороннем сервисе. В этой статье мы подробно разберем, как настроить такой импорт с помощью WP Cron, обработать данные и сохранить их в кастомные типы записей или метаданные.

Почему автоматический импорт из API важен для WordPress-проектов

Ручное обновление контента — это трата времени и риск ошибок. Автоматизация импорта позволяет регулярно синхронизировать данные без участия пользователя. Это особенно актуально для магазинов, новостных сайтов, каталогов и других проектов, где актуальность информации критична.

Кроме того, автоматический импорт помогает:

• Экономить ресурсы команды контента.
• Обеспечить постоянное обновление информации.
• Избежать потери трафика из-за устаревших данных.

Создание базового плагина для импорта из внешнего API с использованием WP Cron

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

Регистрация WP Cron события

Первое, что нужно сделать — зарегистрировать крон-событие, которое будет запускать импорт. Добавим следующий код в файл плагина:

function wpbook_schedule_import_event() {
    if (!wp_next_scheduled('wpbook_import_api_event')) {
        wp_schedule_event(time(), 'hourly', 'wpbook_import_api_event');
    }
}
register_activation_hook(__FILE__, 'wpbook_schedule_import_event');

register_deactivation_hook(__FILE__, function() {
    wp_clear_scheduled_hook('wpbook_import_api_event');
});

Здесь мы создаём событие, которое будет запускаться каждый час. При активации плагина оно регистрируется, при деактивации — удаляется.

Обработчик события импорта

Далее, нужно повесить функцию на это событие:

add_action('wpbook_import_api_event', 'wpbook_handle_import_api');

function wpbook_handle_import_api() {
    $response = wp_remote_get('https://api.example.com/data');
    if (is_wp_error($response)) {
        error_log('wpbook_import_api: Ошибка запроса API');
        return;
    }

    $body = wp_remote_retrieve_body($response);
    $data = json_decode($body, true);
    if (empty($data)) {
        error_log('wpbook_import_api: Пустой ответ API');
        return;
    }

    foreach ($data as $item) {
        wpbook_save_imported_item($item);
    }
}

В этой функции мы делаем запрос к API, проверяем ответ и декодируем JSON в массив. Затем пробегаемся по элементам и передаем их на сохранение.

Сохранение данных в кастомные записи

Для примера создадим кастомный тип записи imported_item и будем сохранять туда данные:

function wpbook_register_custom_post_type() {
    register_post_type('imported_item', array(
        'labels' => array('name' => 'Импортированные элементы'),
        'public' => false,
        'show_ui' => true,
        'supports' => array('title', 'editor'),
    ));
}
add_action('init', 'wpbook_register_custom_post_type');

function wpbook_save_imported_item($item) {
    $existing = get_posts(array(
        'post_type' => 'imported_item',
        'meta_key' => 'wpbook_external_id',
        'meta_value' => $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_title' => sanitize_text_field($item['title']),
            'post_content' => sanitize_textarea_field($item['description']),
            'post_status' => 'publish',
            'post_type' => 'imported_item',
        ));
        add_post_meta($post_id, 'wpbook_external_id', $item['id'], true);
    }
}

В этой функции мы проверяем, есть ли уже запись с таким внешним ID, чтобы не дублировать данные. Если есть — обновляем, если нет — создаем новую.

Обработка ошибок и логирование

Для надежности важно логировать ошибки и исключения, чтобы быстро выявлять проблемы с импортом. В примерах выше используется error_log, но для удобства можно подключить плагин Clearfy Pro с функцией расширенного логирования ошибок с привязкой к WP Cron.

Расширение функционала: фильтрация, кэширование и уведомления

Чтобы импорт был эффективным, добавим несколько улучшений:

• Фильтрация данных: проверять, нужны ли конкретные записи, например, только с определенным статусом или категорией.
• Кэширование ответов API: чтобы не перегружать сервер и избежать лишних запросов.
• Уведомления по email: отправлять администратору отчеты о результате импорта.

Пример простой фильтрации:

function wpbook_handle_import_api() {
    // ... запрос и декодирование
    foreach ($data as $item) {
        if ($item['status'] !== 'active') {
            continue; // пропускаем неактивные
        }
        wpbook_save_imported_item($item);
    }
}

Полезные плагины для автоматизации и улучшения импорта на WordPress

В дополнение к собственным решениям, рекомендуем обратить внимание на следующие плагины:

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

Выводы и рекомендации по автоматическому импорту из API в WordPress

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