PHP와 Elasticsearch를 사용하여 결과 집계 및 분석을 수행하는 방법

require 'vendor/autoload.php';
$hosts = [
    'localhost:9200' // Elasticsearch服务端的地址和端口
];
$client = ElasticsearchClientBuilder::create()
             ->setHosts($hosts)
             ->build();

$params = [
    'index' => 'my_index', // 索引名称
    'body'  => [
        'settings' => [
            'number_of_shards' => 1,
            'number_of_replicas' => 0
        ],
    ],
];
$response = $client->indices()->create($params);

$params = [
    'index' => 'my_index', // 索引名称
    'type' => 'my_type', // 文档类型
    'body' => [
        'my_type' => [
            'properties' => [
                'title' => [
                    'type' => 'text'
                ],
                'content' => [
                    'type' => 'text'
                ],
                'date' => [
                    'type' => 'date'
                ],
                // 其他字段...
            ]
        ]
    ]
];
$response = $client->indices()->putMapping($params);

$params = [
    'index' => 'my_index', // 索引名称
    'type' => 'my_type', // 文档类型
    'body' => [
        'title' => 'Elasticsearch', // 文档字段及对应的值
        'content' => 'Elasticsearch is a distributed, RESTful search and analytics engine.',
        'date' => '2021-01-01'
        // 其他字段...
    ]
];
$response = $client->index($params);

$params = [
    'index' => 'my_index', // 索引名称
    'type' => 'my_type', // 文档类型
    'body' => [
        'query' => [ // 查询参数
            'match' => [
                'content' => 'Elasticsearch'
            ]
        ],
        'aggs' => [ // 聚合参数
            'group_by_date' => [
                'date_histogram' => [
                    'field' => 'date',
                    'interval' => 'month'
                ]
            ],
            // 其他聚合参数...
        ]
    ]
];
$response = $client->search($params);

$response = $client->search($params);
$result = $response['aggregations']['group_by_date']['buckets'];
foreach($result as $bucket) {
    $date = $bucket['key_as_string'];
    $count = $bucket['doc_count'];
    // 打印结果...
}