Как выполнить запрос на чтение данных из InfluxDB?

@gussie.jones 

Для выполнения запроса на чтение данных из InfluxDB можно использовать язык запросов InfluxQL или Flux.

1. Используя InfluxQL:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

from influxdb import InfluxDBClient

# Подключение к InfluxDB
client = InfluxDBClient(host='localhost', port=8086)

# Выбор базы данных
client.switch_database('mydb')

# Выполнение запроса
query = 'SELECT * FROM measurement_name LIMIT 10'
result = client.query(query)

# Обработка результатов запроса
for point in result.get_points():
    print(point)

1. Используя Flux:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

from influxdb import InfluxDBClient

# Подключение к InfluxDB
client = InfluxDBClient(host='localhost', port=8086)

# Выбор базы данных
client.switch_database('mydb')

# Выполнение запроса
query = 'from(bucket: "my-bucket") |> range(start: -1d) |> filter(fn: (r) => r._measurement == "measurement_name")'
result = client.query_api().query(query)

# Обработка результатов запроса
for table in result:
    for record in table.records:
        print(record.values)

В обоих случаях необходимо установить библиотеку InfluxDB для Python, если она не установлена:

1

pip install influxdb

Замените localhost, 8086, mydb, measurement_name и my-bucket на соответствующие значения для вашей конфигурации InfluxDB.

@gussie.jones 

Для выполнения запроса на чтение данных из InfluxDB вы можете использовать язык запросов InfluxQL или Flux.

1. Используя InfluxQL: Откройте консоль InfluxDB или используйте клиентский инструмент, такой как InfluxDB CLI или InfluxDB UI. Выполните команду USE <имя_базы_данных> для выбора нужной базы данных. Далее можете выполнить запросы в соответствии с синтаксисом InfluxQL, например: SELECT * FROM <имя_измерения> WHERE <условие>
2. Используя Flux (начиная с версии InfluxDB 2.0): Откройте консоль InfluxDB или используйте клиентский инструмент, такой как InfluxDB CLI или InfluxDB UI. Выполните команду influx для перехода в режим Flux. После перехода в режим Flux, вы можете выполнить запросы, используя синтаксис Flux, например: from(bucket: "<имя_бакета>") |> range(start: <начальное_время>, stop: <конечное_время>) |> filter(fn: (r) => <условие>) |> yield()

Обратите внимание, что для выполнения запросов в InfluxDB вы должны иметь правильные разрешения доступа и настроенное подключение к серверу InfluxDB.