如何在Pimcore项目中轻松管理多个Elasticsearch客户端？pimcore/elasticsearch-client助你高效集成！

composer require pimcore/elasticsearch-client

# config/packages/pimcore_elasticsearch_client.yaml
pimcore_elasticsearch_client:
    es_clients:
        default: # 默认客户端，用于常规搜索
            hosts: ['elastic:9200']
            username: 'elastic'
            password: 'somethingsecret'
            logger_channel: 'pimcore.elasicsearch'
        statistics: # 统计客户端，连接到另一个集群
            hosts: ['statistics-node:9200']
            logger_channel: 'pimcore.statistics'
            # 可选的SSL/HTTP配置，增强安全性与灵活性
            ca_bundle: 'path/to/ca/cert'
            ssl_key: 'path/to/ssl/key'
            ssl_cert: 'path/to/ssl/cert'
            ssl_password: 'secretePW'
            ssl_verification: false # 生产环境建议保持true
            http_options:
                proxy: 'http://localhost:8125'
        cloud: # 云端Elasticsearch客户端
            cloud_id: '123456789'
            api_key: 'secret-apikey'

<?php

namespace App\Service;

use Elasticsearch\Client;
use Psr\Log\LoggerInterface;

class ProductSearchService
{
    private Client $defaultElasticsearchClient;
    private Client $statisticsElasticsearchClient;
    private LoggerInterface $logger;

    public function __construct(
        Client $pimcoreElasticsearchClientDefault, // 注入默认客户端
        Client $pimcoreElasticsearchClientStatistics, // 注入统计客户端
        LoggerInterface $logger
    ) {
        $this->defaultElasticsearchClient = $pimcoreElasticsearchClientDefault;
        $this->statisticsElasticsearchClient = $pimcoreElasticsearchClientStatistics;
        $this->logger = $logger;
    }

    public function searchProducts(string $query): array
    {
        $params = [
            'index' => 'products',
            'body'  => [
                'query' => [
                    'match' => [
                        'name' => $query
                    ]
                ]
            ]
        ];

        try {
            $response = $this->defaultElasticsearchClient->search($params);
            // 处理搜索结果
            return $response['hits']['hits'];
        } catch (\Exception $e) {
            $this->logger->error('Elasticsearch search failed: ' . $e->getMessage());
            return [];
        }
    }

    public function logSearchQuery(string $query): void
    {
        // 使用统计客户端记录搜索日志
        $this->statisticsElasticsearchClient->index([
            'index' => 'search_logs',
            'body' => [
                'query' => $query,
                'timestamp' => date('Y-m-d H:i:s')
            ]
        ]);
    }
}