PHP と Elasticsearch を使用してリアルタイムの監視および統計機能を構築する方法

PHP と Elasticsearch によるリアルタイム監視および統計機能の構築方法

インターネットの発展に伴い、さまざまな分野でリアルタイム監視および統計機能の重要性が高まっています。広く使用されているサーバー側プログラミング言語である PHP を強力な検索エンジン Elasticsearch と組み合わせることで、効率的なリアルタイムのデータ分析と監視を実現できます。この記事では、PHP と Elasticsearch を使用してリアルタイム監視および統計関数を構築する方法を紹介し、対応するコード例を示します。

1. Elasticsearch のインストールと設定

まず、Elasticsearch をインストールして設定する必要があります。 Elasticsearch は、大量のデータを迅速に保存、検索、分析できるオープンソースの分散検索および分析エンジンです。最新バージョンの Elasticsearch は、Elasticsearch 公式 Web サイト (https://www.elastic.co) からダウンロードしてインストールできます。

インストールが完了したら、Elasticsearch を構成する必要があります。 Elasticsearch 設定ファイル elasticsearch.yml を開き、次の設定を行います。

cluster.name: my-cluster //Elasticsearch クラスターの名前を設定します
node.name: my-node //現在のノードの名前 名前はカスタマイズ可能
network.host: 127.0.0.1 //リスニング アドレスを設定します。デフォルトはローカル アドレスです。
http.port: 9200 //リスニング ポートを設定します。デフォルトはローカル アドレスです。は 9200

Elasticsearch サービスを保存して再起動し、構成が成功したことを確認します。

2. PHP を使用して Elasticsearch に接続する

次に、PHP を使用して Elasticsearch に接続する必要があります。 PHP は、Elasticsearch と対話するために使用される公式 Elasticsearch クライアント ライブラリである Elasticsearch-PHP を提供します。詳細な使用手順とサンプル コードは、公式ドキュメント (https://www.elastic.co/guide/en/elasticsearch/client/php-api/current/index.html) で参照できます。

Composer を使用して Elasticsearch-PHP をインストールします:

composer require elasticsearch/elasticsearch

PHP ファイルに Elasticsearch-PHP ライブラリを導入します:

require 'ベンダー /autoload.php';
ElasticsearchClientBuilder を使用;

Elasticsearch に接続:

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

この時点で、PHP を使用して Elasticsearch に正常に接続しました。

3. リアルタイム監視と統計機能

次に、リアルタイム監視と統計機能を実現する方法を例を使って説明します。

電子商取引 Web サイトがあり、毎日の製品販売とユーザーの訪問をリアルタイムで監視したいとします。 PHP と Elasticsearch を使用して、このデータをカウントし、取得できます。

1. インデックスの作成

まず、データを保存するためのインデックスを作成する必要があります。 PHP ファイルを開き、次のコードを記述します:

$params = [
'index' => 'sales', //インデックス名
'body' => [

'settings' => [
  'number_of_shards' => 1,
  'number_of_replicas' => 0
]

]
];

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

このコードは sales という名前のディレクトリを作成します索引。

2. ドキュメントの追加

次に、いくつかのドキュメントをインデックスに追加する必要があります。各ドキュメントが製品の販売とユーザーの訪問を表すと仮定すると、次のコードを書くことができます:

$params = [
'index' => 'sales',
'body' => ; [

'sales' => [
  '_index' => 'sales',
  '_type' => 'document',
  '_id' => '1',
  '_source' => [
    'product' => 'iPhone',
    'quantity' => 10,
    'price' => 999,
    'timestamp' => date('Y-m-d H:i:s')
  ]
],
'views' => [
  '_index' => 'sales',
  '_type' => 'document',
  '_id' => '2',
  '_source' => [
    'product' => 'MacBook',
    'quantity' => 5,
    'price' => 1999,
    'timestamp' => date('Y-m-d H:i:s')
  ]
]

]
];

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

このコードは、2 つのドキュメントをインデックスに追加します。

3. リアルタイムの監視と統計

実際のアプリケーションでは、通常、いくつかの条件に基づいてデータをクエリし、集計する必要があります。たとえば、特定の期間内の製品の売上をクエリしたり、製品名ごとにグループ統計を実行したりする必要がある場合があります。

次のサンプル コードは、特定の時間範囲内の製品の売上をクエリする方法を示しています:

$params = [
'index' => 'sales',
'body' => [

'query' => [
  'range' => [
    'timestamp' => [
      'gte' => '2022-01-01T00:00:00',
      'lt' => '2022-01-02T00:00:00'
    ]
  ]
],
'aggs' => [
  'total_sales' => [
    'sum' => [
      'field' => 'quantity'
    ]
  ]
]

]
];

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

上記のコード2022 年 1 月 1 日の製品販売数量をクエリし、合計販売数量を返します。

これまでに、PHP と Elasticsearch を使用してリアルタイム監視および統計機能を構築する例を実装することに成功しました。

概要:

この記事では、PHP と Elasticsearch を使用してリアルタイム監視および統計関数を構築する方法を紹介し、対応するコード例を示します。 Elasticsearch-PHP ライブラリを使用すると、Elasticsearch と簡単に対話して、効率的なリアルタイムのデータ分析とモニタリングを実現できます。誰でも PHP と Elasticsearch を学び、使用して、リアルタイムの監視機能と統計機能を構築することを歓迎します。

以上がPHP と Elasticsearch を使用してリアルタイムの監視および統計機能を構築する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。