PHP 中使用 Elasticsearch 进行数据清洗与聚合计算

// 引入 Elasticsearch 客户端库
require 'vendor/autoload.php';

// 创建 Elasticsearch 客户端
$client = ElasticsearchClientBuilder::create()->build();

// 索引名称
$index = 'my-index';

// 数据清洗和聚合计算
$params = [
    'index' => $index,
    'body' => [
        'query' => [
            'match' => [
                'field' => 'value'
            ]
        ],
        'aggs' => [
            'sum_field' => [
                'sum' => [
                    'field' => 'value'
                ]
            ]
        ]
    ]
];

// 发送查询请求
$response = $client->search($params);

// 处理响应数据
$results = $response['hits']['hits'];
$aggregations = $response['aggregations']['sum_field'];

// 输出结果
foreach ($results as $result) {
    echo $result['_source']['field'] . "
";
}

echo "聚合计算结果: " . $aggregations['value']['value'] . "
";