妙音 -

问题描述

influx查询包含了水平拆分、垂直拆分. 查询结果的每一条记录record，只对应一个field

写入一个point时包含多个field, 查询时如何将这几个field一起查出来呢？

写入示例

point := influxdb2.NewPoint("history",
    map[string]string{
        "Version": DedefaultVersion,
        "Name": sh.Name,
        "Active": fmt.Sprintf("%v", sh.Active),
        "PortIdx": fmt.Sprintf("%d", sh.PortIdx),
        "Port": fmt.Sprintf("%v", sh.Port),
    },
    map[string]interface{}{
        "MsgId": fmt.Sprintf("%d", sh.MsgId),
        "Content": sh.Content,
    },
    time.Now(),
    )

* 查询

from(bucket:"my-bucket")
|> range(start: -10m)
|> filter(fn: (r) => (r._measurement=="history") and (r.Name=="xxxx") )

用这个方法查询, 每个record只包含一个_field

解决方法: 分组

分组之后的record，会多一个table属性。table相同，则为一组。也就是一个point的field。

* 按写入时间分组

1	`\|> group(columns: ["_time"])`

* 增加id标签，按id分组

为每个point增加一个id标签, 然后按id分组

influxdb的docker-compose如何配置

1. 新建数据目录

1	`mkdir` `data-volumne`

2. 生成配置文件

1	`docker run --rm` `influxdb:2.0.8 influxd print-config > config.yml`

3. docker-compose配置

docker-compose.yaml内容

version: "2"
services:
   influxdb:
       image: influxdb:2.0.8
       volumes:
           - ./data-volumne:/var/lib/influxdb2
           - ./config.yml:/etc/influxdb2/config.yml
           - /usr/share/zoneinfo/Asia/Shanghai:/etc/localtime
       ports:
           - 8086:8086
       environment:
           DOCKER_INFLUXDB_INIT_MODE: setup
           DOCKER_INFLUXDB_INIT_USERNAME: my-user
           DOCKER_INFLUXDB_INIT_PASSWORD: my-password
           DOCKER_INFLUXDB_INIT_ORG: my-org
           DOCKER_INFLUXDB_INIT_BUCKET: my-bucket

4. 启动

1	`docker-compose up`

5. 目录结构如下

[root@localhost influxdb]# tree
.
├── config.yml
├── data-volumne
│   ├── engine
│   │   └── data
│   └── influxd.bolt
└── docker-compose.yaml

* 注意

上面修改influx时区无效，好像不能修改时区，默认都是UTC