RiSearch + PHP ist eine Komplettlösung für die effiziente Suche und Aggregation von Zeitreihendaten

Einführung

Mit der kontinuierlichen Weiterentwicklung von Internetanwendungen generiert das System immer mehr Zeitreihendaten wie Sensordaten, Protokollinformationen, Aktienkurse usw. Diese Art von Daten zeichnet sich durch Zeitkontinuität und hohes Wachstum aus. Die effiziente Suche und Aggregation ist zu einer wichtigen technischen Herausforderung geworden. In diesem Artikel wird vorgestellt, wie Sie eine leistungsstarke Lösung für die Suche und Aggregation von Zeitreihendaten basierend auf RiSearch und PHP erstellen.

Umgebungskonfiguration von RiSearch und PHP

Vor der Implementierung müssen Sie Redis, RiSearch und die Redis-Erweiterung von PHP installieren. Das Folgende ist der grundlegende Konfigurationsprozess:

• Redis installieren: Informationen zu Download- und Installationsmethoden finden Sie in der offiziellen Redis-Dokumentation.
• Installieren Sie RiSearch: Laden Sie es aus dem offiziellen GitHub-Repository herunter und schließen Sie die Kompilierung und Installation ab.
• Installieren Sie die PHP Redis-Erweiterung: Verwenden Sie den Befehl pecl install redis, um sie zu installieren und in der PHP-Konfigurationsdatei zu aktivieren.

Erstellen Sie einen Zeitreihenindex

Die Verwendung von Indizes in RiSearch ist die Grundlage für die Suche und Aggregation. Das folgende Beispiel zeigt, wie man in PHP einen logbasierten Zeitreihenindex erstellt:

<?php
$redis = new Redis();
$redis-> connect(&#39;127.0.0.1&#39;, 6379);

$redis->rawCommand(&#39;FT.CREATE&#39;, &#39;logs&#39;, &#39;SCHEMA&#39;, &#39;timestamp&#39;, &#39;NUMERIC&#39;, &#39;content&#39;, &#39;TEXT&#39;);

// Protokolldaten zum Index hinzufügen $logs = array(
    array(&#39;timestamp&#39; => 1615516800, &#39;content&#39; => &#39;Dies ist das erste Protokoll&#39;),
    array(&#39;timestamp&#39; => 1615603200, &#39;content&#39; => &#39;Dies ist das zweite Protokoll&#39;),
    // ...
);

foreach ($logs als $log) {
    $redis->rawCommand(&#39;FT.ADD&#39;, &#39;logs&#39;, &#39;doc:&#39;.$log[&#39;timestamp&#39;], 1.0, &#39;FIELDS&#39;,
        &#39;Zeitstempel&#39;, $log[&#39;Zeitstempel&#39;],
        &#39;content&#39;, $log[&#39;content&#39;]);
}
?>

Der obige Code definiert zunächst einen Index mit dem Namen logs , der zwei Felder enthält: Zeitstempel und Inhalt, und mehrere Protokolldaten in den Index schreibt, um nachfolgende Such- und Aggregationsvorgänge zu erleichtern.

Suchen Sie nach Zeitreihendaten

RiSearch bietet eine effiziente Abfragesyntax zum schnellen Abrufen von Daten basierend auf Zeitintervallen. Der folgende Code zeigt, wie Protokolle innerhalb eines bestimmten Zeitraums durchsucht werden:

<?php
$redis = new Redis();
$redis-> connect(&#39;127.0.0.1&#39;, 6379);

$query = &#39;@timestamp:[1615516800 1615603200]&#39;; // Protokolle vom 12.03.2021 bis 13.03.2021 durchsuchen $result = $redis->rawCommand(&#39;FT.SEARCH&#39;, &#39;logs&#39;, $query, &#39;LIMIT&#39;, 0, 10);

// Suchergebnisse foreach ausgeben ($result as $key => $value) {
    if ($key % 2 === 0) {
        echo &#39;Log-ID:&#39;.$value."\n";
    } anders {
        echo &#39;Content:&#39;.$value."\n";
    }
}
?>

Mit dem Befehl FT.SEARCH können wir Protokollinformationen innerhalb eines Zeitbereichs schnell abfragen und die Ergebnisse bei Bedarf ausgeben. Diese Methode kann komplexe Abfragebedingungen und den Abgleich mehrerer Felder unterstützen.

Aggregieren Sie Zeitreihendaten

In Protokollanalyse- oder Überwachungssystemen sind aggregierte Statistiken eine häufige Anforderung. Sie können beispielsweise zählen, wie oft ein bestimmter Protokolltyp innerhalb eines bestimmten Zeitraums angezeigt wird. Das folgende Beispiel zeigt die Verwendung des Aggregationsbefehls von RiSearch, um diese Funktionalität zu erreichen:

<?php
$redis = new Redis();
$redis-> connect(&#39;127.0.0.1&#39;, 6379);

$query = &#39;@timestamp:[1615516800 1615603200]&#39;; // Nach Protokollen im angegebenen Zeitbereich suchen $result = $redis->rawCommand(&#39;FT.AGGREGATE&#39;, &#39;logs&#39;, $query, &#39;LOAD&#39;, 1,
    &#39;GROUPBY&#39;, 1, &#39;@content&#39;,
    &#39;REDUCE&#39;, &#39;COUNT&#39;, 0, &#39;AS&#39;, &#39;count&#39;);

// Das Aggregationsergebnis ausgeben foreach ($result as $item) {
    echo &#39;Content:&#39;.$item[&#39;@content&#39;].&#39;, Häufigkeit des Auftretens: &#39;.$item[&#39;count&#39;]."\n";
}
?>

Dieser Aggregationsbefehl gruppiert die Abfrageergebnisse und zählt die Auftrittszeiten jedes Protokollinhalts. Es eignet sich sehr gut für Szenarien wie Protokollanalyse und Ereignisstatistik.

Zusammenfassen

Durch die Kombination von RiSearch und PHP können wir problemlos ein Hochleistungssystem aufbauen, das die Suche und Aggregation von Zeitreihendaten unterstützt. Durch die drei Schritte Indexerstellung, Suchanfrage und Aggregationsanalyse können umfangreiche Zeitreihendaten effizient verwaltet und analysiert werden. Entwickler können basierend auf den tatsächlichen Geschäftsanforderungen weitere Erweiterungen vornehmen, indem sie beispielsweise Funktionen wie Datenvisualisierung, intelligente Alarme oder mehrdimensionale Aggregation hinzufügen, um eine vollständige Datenanalyseplattform aufzubauen.