PHP 中 Elasticsearch 实现大数据分析与挖掘技术探索

<?php
require 'vendor/autoload.php';

$client = ElasticsearchClientBuilder::create()->build();

$params = [
    'index' => 'my_index',
    'body' => [
        'settings' => [
            'number_of_shards' => 3,
            'number_of_replicas' => 2
        ],
        'mappings' => [
            'properties' => [
                'title' => ['type' => 'text'],
                'content' => ['type' => 'text'],
                'author' => ['type' => 'keyWord'],
                'cateGory' => ['type' => 'keyword'],
                'timestamp' => ['type' => 'date'],
            ]
        ]
    ]
];

$response = $client->indices()->create($params);

$params = [
    'index' => 'my_index',
    'body' => [
        ['index' => ['_index' => 'my_index', '_id' => '1']],
        ['title' => '文章标题1', 'content' => '文章内容1', 'author' => '作者1', 'category' => '分类1', 'timestamp' => '2021-01-01'],
        ['index' => ['_index' => 'my_index', '_id' => '2']],
        ['title' => '文章标题2', 'content' => '文章内容2', 'author' => '作者2', 'category' => '分类2', 'timestamp' => '2021-01-02'],
    ]
];

$response = $client->bulk($params);

?>

<?php
require 'vendor/autoload.php';

$client = ElasticsearchClientBuilder::create()->build();

$params = [
    'index' => 'my_index',
    'body' => [
        'query' => [
            'match' => ['title' => '关键字']
        ],
        'aggs' => [
            'avg_score' => [
                'avg' => ['field' => 'score']
            ]
        ]
    ]
];

$response = $client->search($params);

foreach ($response['hits']['hits'] as $hit) {
    echo $hit['_source']['title'] . "<br>";
}

echo '平均分数：' . $response['aggregations']['avg_score']['value'];

?>