Інтеграція Elasticsearch з 1С-Бітрікс

Інтеграція Elasticsearch з Bitrix CMS

Вбудований пошук Bitrix спирається на таблиці b_search_content та b_search_content_stem — морфологічний індекс на базі MySQL/MariaDB. Коли індексовано 50–100 тисяч документів, запити повнотекстового пошуку починають давати затримки 200–500 мс. Для каталогів з мільйоном товарів або при необхідності складних фільтрів пошуку (діапазон ціни, кілька фасетів одночасно), вбудований пошук не справляється. Elasticsearch вирішує обидві проблеми: видає результати за 5–30 мс та підтримує довільну агрегацію.

Архітектура інтеграції

Інтеграція складається з трьох частин:

1. Індексатор — компонент, який читає дані з Bitrix (елементи інфоблоку, користувачів, сторінок) та записує документи в індекс Elasticsearch.
2. Пошуковий шлюз — замінює стандартні запити до b_search_content запитами до Elasticsearch API.
3. Обробники подій — оновлюють індекс при зміні або видаленні сутностей.

Структура індексу для каталогу товарів

Індекс створюється через Elasticsearch Mapping API. Приклад маппінгу для товарів:

PUT /bitrix_catalog
{
  "mappings": {
    "properties": {
      "id":          { "type": "integer" },
      "iblock_id":   { "type": "integer" },
      "name":        { "type": "text", "analyzer": "russian" },
      "description": { "type": "text", "analyzer": "russian" },
      "sku":         { "type": "keyword" },
      "price":       { "type": "float" },
      "active":      { "type": "boolean" },
      "section_id":  { "type": "integer" },
      "properties":  { "type": "object" },
      "updated_at":  { "type": "date" }
    }
  },
  "settings": {
    "analysis": {
      "analyzer": {
        "russian": {
          "type": "custom",
          "tokenizer": "standard",
          "filter": ["lowercase", "russian_stop", "russian_stemmer"]
        }
      },
      "filter": {
        "russian_stemmer": { "type": "stemmer", "language": "russian" },
        "russian_stop":    { "type": "stop", "stopwords": "_russian_" }
      }
    }
  }
}

Аналізатор russian з стеммером — ключова відмінність від MySQL FULLTEXT, який без додаткових словників не розуміє морфологію.

Індексування даних

Первинне індексування запускається через cron-скрипт. Дані читаються пакетами через CIBlockElement::GetList() з nTopCount = 100 та зміщенням, щоб не перевантажити пам'ять:

\Bitrix\Main\Loader::includeModule('iblock');

$client = new \Elasticsearch\ClientBuilder::create()
    ->setHosts(['localhost:9200'])
    ->build();

$offset = 0;
$batchSize = 100;

do {
    $res = \CIBlockElement::GetList(
        [],
        ['IBLOCK_ID' => CATALOG_IBLOCK_ID, 'ACTIVE' => 'Y'],
        false,
        ['nTopCount' => $batchSize, 'nPageSize' => $batchSize, 'iNumPage' => floor($offset / $batchSize) + 1],
        ['ID', 'NAME', 'DETAIL_TEXT', 'IBLOCK_ID', 'IBLOCK_SECTION_ID']
    );

    $bulk = [];
    while ($item = $res->GetNext()) {
        $bulk[] = ['index' => ['_index' => 'bitrix_catalog', '_id' => $item['ID']]];
        $bulk[] = [
            'id'         => (int)$item['ID'],
            'iblock_id'  => (int)$item['IBLOCK_ID'],
            'name'       => $item['NAME'],
            'description'=> strip_tags($item['DETAIL_TEXT']),
            'section_id' => (int)$item['IBLOCK_SECTION_ID'],
            'active'     => true,
            'updated_at' => date('c'),
        ];
        $offset++;
    }

    if (!empty($bulk)) {
        $client->bulk(['body' => $bulk]);
    }
} while ($res->SelectedRowsCount() === $batchSize);

Bulk API дозволяє надсилати до 1000 документів за один запит. Не використовуйте окремі index-запити для первинного індексування — це в 10–50 разів повільніше.

Оновлення індексу при зміні товару

Підписуємось на події інфоблоку:

// local/php_interface/init.php
AddEventHandler('iblock', 'OnAfterIBlockElementUpdate', 'esUpdateProduct');
AddEventHandler('iblock', 'OnAfterIBlockElementDelete', 'esDeleteProduct');

function esUpdateProduct(array &$arFields): void
{
    $client = getEsClient();
    $productId = (int)$arFields['ID'];
    // Переіндексувати один документ
    $client->index([
        'index' => 'bitrix_catalog',
        'id'    => $productId,
        'body'  => buildProductDocument($productId),
    ]);
}

function esDeleteProduct(int $productId): void
{
    getEsClient()->delete(['index' => 'bitrix_catalog', 'id' => $productId]);
}

Подія OnAfterIBlockElementUpdate спрацьовує навіть при зміні через API (імпорт з 1С), що важливо для актуальності індексу.

Пошуковий запит

Заміна стандартного компонента bitrix:search.page на користувацький, що звертається до Elasticsearch:

$response = $client->search([
    'index' => 'bitrix_catalog',
    'body'  => [
        'query' => [
            'multi_match' => [
                'query'     => $searchQuery,
                'fields'    => ['name^3', 'description', 'sku'],
                'type'      => 'best_fields',
                'fuzziness' => 'AUTO',
            ],
        ],
        'sort'  => ['_score' => ['order' => 'desc']],
        'from'  => ($page - 1) * $pageSize,
        'size'  => $pageSize,
    ],
]);

Параметр fuzziness: AUTO забезпечує пошук з опечатками: для слів до 5 символів допускається 1 заміна, для довших — 2.

Терміни впровадження