访问 InfluxDB 2.0 记录中的多个字段

Posted

技术标签:

【中文标题】访问 InfluxDB 2.0 记录中的多个字段【英文标题】:Accessing multiple fields in InfluxDB 2.0 records 【发布时间】:2021-07-26 23:16:12 【问题描述】:

我是 InfluxDB 2.0 的新手,我正在构建一个时间序列数据库,我在其中存储每个点的多个字段(XAUUSD 货币的价格值)。

虽然我能够按预期存储它;当我获取记录时,我似乎无法获取每条记录可访问的所有字段。

这是我如何将一些虚拟数据写入 DB 的代码 sn-p:

from datetime import datetime
import time
import influxdb_client
from influxdb_client.client.write_api import SYNCHRONOUS
import random

token = "XXX"
org = "Trader"
bucket = "Master"
url="http://localhost:8086"

client = influxdb_client.InfluxDBClient(
    url=url,
    token=token,
    org=org
)

write_api = client.write_api(write_options=SYNCHRONOUS)
while True:
    p = influxdb_client.Point("D1").tag("currency", "XAUUSD").field("open", random.randint(900,1100)).field("close", random.randint(900,1100)).time(datetime.utcnow(), influxdb_client.WritePrecision.NS)
    write_api.write(bucket=bucket, org=org, record=p)
    time.sleep(1)

我正在尝试将数据读回:

query_api = client.query_api()
query = ' from(bucket:"Master")\
|> range(start: -5h)\
|> filter(fn:(r) => r._measurement == "D1")\
|> filter(fn: (r) => r.currency == "XAUUSD")\
|> filter(fn:(r) => r["_field"] == "close" or r["_field"] == "open")'

result = client.query_api().query(org=org, query=query)

for table in result:
  for record in table.records:
    results.append((record.get_field(), record.get_value()))

print(results)

问题是;每行结果如下:

'result': '_result', 'table': 1, '_start': datetime.datetime(2021, 5, 4, 8, 58, 35, 12587, tzinfo=tzutc()), '_stop': datetime.datetime(2021, 5, 4, 13, 58, 35, 12587, tzinfo=tzutc()), '_time': datetime.datetime(2021, 5, 4, 13, 12, 56, 86095, tzinfo=tzutc()), '_value': 961, '_field': 'open', '_measurement': 'D1', 'currency': 'XAUUSD'

并且它没有显示两个字段;打开和关闭(它们显示为单独的行,其中 _field 对于一个条目是“打开”,对于第二个条目是“关闭”对于同一条目。

有没有一种方法可以让结果行在一个结果中包含两个字段值而不是 2;每个字段 1 个?因为如果我添加更多字段,我将不得不找到一种方法来组合 n 行以获得相同的价格变动。

我尝试过查看 InfluxDB 文档,但所有示例都只显示一个 _field 值而不是多个。

网上有一些答案使用 pivot 和正则表达式,但我认为这不适合我的情况,比如 mysql 中这样的简单查询:

SELECT open, close FROM XAUUSD WHERE interval="D1";

关于如何使用 InfluxDB 解决这个“简单”任务的任何想法或帮助,或者我只是使用了错误的工具来完成这项工作?

【问题讨论】:

【参考方案1】:

我也有同样的问题。This link helped me.

将字段转换为列 使用 pivot() 将 mem_used 和 mem_total 字段转换为列。 输出包括 mem_used 和 mem_total 列,每个列都有值 对应的_time。

query = ' from(bucket:"Master")\
|> range(start: -5h)\
|> filter(fn:(r) => r._measurement == "D1")\
|> filter(fn: (r) => r.currency == "XAUUSD")\
|> filter(fn:(r) => r["_field"] == "close" or r["_field"] == "open")\
|> pivot(rowKey: ["_time"], columnKey: ["_field"], valueColumn: "_value")'  # <- Add this

【讨论】:

以上是关于访问 InfluxDB 2.0 记录中的多个字段的主要内容,如果未能解决你的问题,请参考以下文章

InfluxDB 2.0 中的存储桶、度量和保留策略之间的逻辑联系是啥?

influxdb

influxdb

如何在滚动窗口上“检查”(警告)InfluxDB 2.0 中的聚合?

如何使用组合框在记录 ms 访问中搜索多个字段?

PHP 如何轻松访问PHP中的JSON(如具有多个字段的JSON记录集)