PHP と Kafka を使用したリアルタイムのフライト遅延データ分析

航空業界では、フライトの遅延がよくある問題であり、乗客は旅行中に多くの困難に見舞われます。しかし、航空会社や空港管理者がフライトの遅延をタイムリーに把握し、対応策を講じることは、フライトの定時性やサービスレベルの評価に直接影響するため、非常に重要です。

PHP と Kafka を使用してリアルタイムのフライト遅延データを分析することは、効果的なソリューションです。この記事では、PHP で Kafka を使用して、リアルタイムのフライト遅延データを収集および分析する方法について詳しく説明します。

まず、Kafka 環境をインストールして構成する必要があります。 Ubuntu システムでは、次のコマンドを実行して Kafka をインストールできます:

sudo apt-get update
sudo apt-get install default-jre
wget https://downloads.apache.org/kafka/2.5.0/kafka_2.12-2.5.0.tgz
tar -xzf kafka_2.12-2.5.0.tgz
cd kafka_2.12-2.5.0

次に、Kafka ディレクトリに入り、Kafka サービスを開始します:

bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

これで、Kafka サービスが正常に開始されました。

次に、PHP を使用して Kafka プロデューサー コードを記述します。プロデューサーは、飛行遅延データを Kafka のトピックに送信します。

<?php
$topic = "flight-delay";
$brokerList = "localhost:9092";
$producer = new RdKafkaProducer();
$producer->setLogLevel(LOG_DEBUG);
$producer->addBrokers($brokerList);
$topicObj = $producer->newTopic($topic);
while (true) {
  $message = generateDelayMessage();
  $topicObj->produce(RD_KAFKA_PARTITION_UA, 0, $message);
  sleep(rand(1,5));
}
function generateDelayMessage() {
  $airline = array("AA", "UA", "DL", "WN", "B6");
  $delay = array("15", "30", "45", "60", "75", "90", "120");
  return "airline:".$airline[array_rand($airline)].",delay:".$delay[array_rand($delay)];
}
?>

このコード スニペットは、シミュレートされた飛行遅延データをランダムに生成し、それを Kafka トピックに送信します。次のコマンドを使用してコードを実行できます。

php producer.php

次に、別の PHP コードを使用して、Kafka トピックからのデータを使用して分析できます。

<?php
$topic = "flight-delay";
$brokerList = "localhost:9092";
$groupId = "group1";
$timeoutMs = 1000;
$topicConf = new RdKafkaTopicConf();
$topicConf->set('auto.offset.reset', 'smallest');
$consumerConf = new RdKafkaConf();
$consumerConf->set('group.id', $groupId);
$consumer = new RdKafkaKafkaConsumer($consumerConf);
$consumer->addBrokers($brokerList);
$consumer->subscribe([$topic]);
while (true) {
  $message = $consumer->consume($timeoutMs);
  switch ($message->err) {
    case RD_KAFKA_RESP_ERR_NO_ERROR:
      echo $message->payload;
      analyzeDelayMessage($message->payload);
      break;
    case RD_KAFKA_RESP_ERR__TIMED_OUT:
      break;
    default:
      throw new Exception($message->errstr(), $message->err);
      break;
  }
}
function analyzeDelayMessage($message) {
  $parts = explode(",", $message);
  $airline = substr($parts[0], strpos($parts[0], ":") + 1);
  $delay = substr($parts[1], strpos($parts[1], ":") + 1);
  // Do something with the delay data.
}
?>

このコード スニペットは、 Kafka トピック データを取得し、analyzeDelayMessage() 関数を呼び出してデータを分析します。この機能では、フライトの遅延の程度に応じて適切な措置を講じることができます。

最後に、Web インターフェイスでデータを視覚化して表示できます。これは、Laravel などの PHP フレームワークや Highcharts などの JavaScript ライブラリを使用して実現できます。この Web インターフェイスでは、フライト遅延の傾向を表示し、リアルタイムのフライト遅延データをユーザーに提供できます。

要約すると、PHP と Kafka を使用してリアルタイムのフライト遅延データを分析することは効果的なソリューションです。分散ストリーム処理プラットフォームとして、Kafka はリアルタイム データを効果的に収集して処理するのに役立ちます。 PHP は強力な Web 開発言語として、データを視覚化し、ユーザーに提供するのに役立ちます。

以上がPHP と Kafka を使用したリアルタイムのフライト遅延データ分析の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。