PHP と Elasticsearch によって実装されたリアルタイムの商品価格監視ソリューション

<?php
require 'vendor/autoload.php'; // 导入Elasticsearch客户端库

use ElasticsearchClientBuilder;

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

$params = [
    'index' => 'price_index',
    'body' => [
        'settings' => [
            'number_of_replicas' => 0,
            'number_of_shards' => 1
        ],
        'mappings' => [
            'properties' => [
                'product' => [
                    'type' => 'text'
                ],
                'price' => [
                    'type' => 'double'
                ],
                'timestamp' => [
                    'type' => 'date'
                ]
            ]
        ]
    ]
];

$response = $client->indices()->create($params); // 创建索引

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

use ElasticsearchClientBuilder;

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

$product = 'iPhone 12';
$price = 9999.99;
$timestamp = date('Y-m-d H:i:s');

$params = [
    'index' => 'price_index',
    'id' => uniqid(), // 使用唯一ID作为文档的ID
    'body' => [
        'product' => $product,
        'price' => $price,
        'timestamp' => $timestamp
    ]
];

$response = $client->index($params); // 存储商品价格到索引

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

use ElasticsearchClientBuilder;

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

$product = 'iPhone 12';

$params = [
    'index' => 'price_index',
    'body' => [
        'query' => [
            'match' => [
                'product' => $product
            ]
        ],
        'sort' => [
            'timestamp' => 'desc'
        ],
        'size' => 1
    ]
];

$response = $client->search($params); // 查询最新的商品价格

$latestPrice = $response['hits']['hits'][0]['_source']['price']; // 获取最新的商品价格

// 进行价格比较和调整的逻辑
if ($latestPrice < 9000) {
    // 商品价格过低，进行调整
    // ...
}