InfluxDB3 Enterprise: schnellster Weg, um älteste und jüngste Datetime-Zeilen abzurufen ⇐ Python

[Anonymous]

Ich muss aus einer InfluxDB3 Enterprise-Tabelle mit

• 17 Millionen Zeilen
• 40 Spalten
• vier davon Tags

das Datum und die Uhrzeit der jüngsten und ältesten Zeilen extrahieren. Meine Erwartung war, dass dies extrem schnell gehen würde, wenn InfluxDB für Zeitreihen optimiert wäre. Im Gegensatz dazu habe ich ein großes Problem, da es auf meinem PC mehr als vier Minuten und viel Speicher in Anspruch nimmt. Eine der Abfragen, die ich auf einem Jupyter-Notebook versuche, ist die folgende

Code: Select all

from influxdb_client_3 import InfluxDBClient3
import time

# Config
influx_token = '[YOUR_TOKEN]'
influx_url = "http://127.0.0.1:8181"
influx_bucket = "[your_bucket]"

client = InfluxDBClient3(
host=influx_url,
token=influx_token,
database=influx_bucket
)

measurement = "XOM-option-5m"

query = f'SELECT FIRST(bid), LAST(bid) FROM "{measurement}"'

print(f"[QUERY] {query}")

t0 = time.time()
result = client.query(query, language="influxql")
elapsed = time.time() - t0

df = result.to_pandas() if hasattr(result, "to_pandas") else result

print(f"\n[RESULT] Elapsed: {elapsed:.2f}s")
print(f"[RESULT] Shape: {df.shape}")
print(f"[RESULT] Columns: {list(df.columns)}")
print(f"\n[RESULT] Data:")
print(df)

Ich hoffe, ich mache etwas falsch, sonst bedeutet es, dass ich überhaupt einen Fehler bei der Wahl von InfluxDB gemacht habe!!!
Danke.