查询InfluxDB最后一点
我使用c++库进水cxx cxx，它使用curl将数据插入到数据库中。在我的c++程序中，我将编写4个测量值，每个测量值都有几十个点每秒插入。我使用UDP发送数据。
sensor_->influxdb_ = influxdb::InfluxDBFactory::Get("udp://localhost:8089?db=udp");插入的c++代码之一看起来：
sensor_->influxdb_->write(influxdb::Point("/controller/data")
.addField("angular", sensor_->angular())
.addField("speed_left_rear", sensor_->speedl()
.addField("speed_right_rear", sensor_->speedr()
.addField("voltage", sensor_->voltage()));它将插入一个测量点“/控制器/数据”。这一点有四个字段，没有标签。
当我在数据库的最后半秒钟中查询数据时，就会出现问题。我打开一个终端然后进入
influx
use udp
create retention policy "1h" on udp duration 1h replication 1 shard duration 1h default
precision rfc3339
SELECT * FROM "udp".."/controller/data" WHERE time >= now() - 500ms预期行为：i可以在最后半秒钟内获得点数，所有字段都不是空的，同一行中的数据具有相同的时间戳。实际行为：有时为null。例如：
> SELECT * FROM "udp".."/controller/data" WHERE time >= now() - 500ms
name: /controller/data
time angular speed_left_rear speed_right_rear voltage
---- ------- --------------- ---------------- -------
2021-08-02T08:47:41.17175053Z 99 0 0 23152
2021-08-02T08:47:41.189857794Z -49 0 0 23152
2021-08-02T08:47:41.203743539Z 282 0 0 23152
2021-08-02T08:47:41.219689002Z 299 0 0 23152
2021-08-02T08:47:41.235739755Z 249 0 0 23223
2021-08-02T08:47:41.251701843Z 299 0 0 23311
2021-08-02T08:47:41.267655473Z 133 0 0 23311
2021-08-02T08:47:41.284691461Z 382 0 0 23311
2021-08-02T08:47:41.299605898Z 116 0 0 23240
2021-08-02T08:47:41.315760775Z 23240
2021-08-02T08:47:41.331771862Z 23240
2021-08-02T08:47:41.347798407Z 23240
2021-08-02T08:47:41.363746204Z 23364
2021-08-02T08:47:41.380132952Z 23364
2021-08-02T08:47:41.395660171Z 23364
2021-08-02T08:47:41.411623426Z 23364
2021-08-02T08:47:41.427676221Z 23241
2021-08-02T08:47:41.443633642Z 23241
2021-08-02T08:47:41.459634521Z 23241
2021-08-02T08:47:41.475580859Z 23241
2021-08-02T08:47:41.491627529Z 23400
2021-08-02T08:47:41.507684407Z 23400
2021-08-02T08:47:41.523670412Z 23400
2021-08-02T08:47:41.539542668Z 23400
2021-08-02T08:47:41.556554739Z 23400
2021-08-02T08:47:41.571867004Z 23329
2021-08-02T08:47:41.587669261Z 23329
2021-08-02T08:47:41.603685306Z 23329
2021-08-02T08:47:41.619762893Z 23329
2021-08-02T08:47:41.636273305Z 23293
2021-08-02T08:47:41.651680944Z 23293
2021-08-02T08:47:41.667774571Z 23293
2021-08-02T08:47:41.683901448Z 23293
2021-08-02T08:47:41.699780996Z 23417
2021-08-02T08:47:41.715881623Z 23417
2021-08-02T08:47:41.732012Z 23417
2021-08-02T08:47:41.747715092Z 23417
2021-08-02T08:47:41.763705763Z 23205
2021-08-02T08:47:41.779796182Z 23205
2021-08-02T08:47:41.795692354Z 23205和
> SELECT * FROM "udp".."/controller/data" WHERE time >= now() - 500ms
name: /controller/data
time angular speed_left_rear speed_right_rear voltage
---- ------- --------------- ---------------- -------
2021-08-02T08:49:30.314298081Z 649 0 0 23293
2021-08-02T08:49:30.330174725Z 316 0 0 23293
2021-08-02T08:49:30.346282365Z 798 0 0 23187
2021-08-02T08:49:30.362351798Z 732 0 0 23187
2021-08-02T08:49:30.378310691Z 282 0 0 23187
2021-08-02T08:49:30.39422Z 549 0 0 23293
2021-08-02T08:49:30.410205143Z 615 0 0 23329
2021-08-02T08:49:30.42628595Z 149 0 0 23329
2021-08-02T08:49:30.442316883Z 282 0 0 23329
2021-08-02T08:49:30.45822561Z 582 0 0 23329
2021-08-02T08:49:30.474172836Z 133 0 0 23364
2021-08-02T08:49:30.490214269Z 233 0 0 23364
2021-08-02T08:49:30.506210203Z 549 0 0 23364
2021-08-02T08:49:30.522200303Z -399 0 0 23364
2021-08-02T08:49:30.538234736Z -366 0 0 23364
2021-08-02T08:49:30.554288127Z 0 23364
2021-08-02T08:49:30.570351727Z 0 23364
2021-08-02T08:49:30.586195413Z 0 23364
2021-08-02T08:49:30.602191055Z 0 23241
2021-08-02T08:49:30.618195155Z 0 23241
2021-08-02T08:49:30.634950578Z 0 23241
2021-08-02T08:49:30.650237772Z 0 23223
2021-08-02T08:49:30.666386828Z 0 23276
2021-08-02T08:49:30.682325013Z 0 23276
2021-08-02T08:49:30.698237823Z 0 23276
2021-08-02T08:49:30.714291797Z 0 23276
2021-08-02T08:49:30.730265564Z 0 23099
2021-08-02T08:49:30.746241957Z 0 23099
2021-08-02T08:49:30.762230307Z 0 23099
2021-08-02T08:49:30.778286615Z 0 23099
2021-08-02T08:49:30.794283132Z 0 22993
2021-08-02T08:49:30.819896051Z 0 23134
2021-08-02T08:49:30.826242917Z 0 23134
2021-08-02T08:49:30.84235989Z 0 23134
2021-08-02T08:49:30.86443611Z 0 23134
2021-08-02T08:49:30.874357007Z 0 23170
2021-08-02T08:49:30.890441315Z 0 23170
2021-08-02T08:49:30.906395249Z 0 23170
2021-08-02T08:49:30.922352392Z 0 23170
2021-08-02T08:49:30.942798927Z 0 23187
2021-08-02T08:49:30.954241427Z 0 23187
2021-08-02T08:49:30.970329818Z 0 23187
2021-08-02T08:49:30.986202379Z 0 23240
2021-08-02T08:49:31.002118397Z 0 23046
2021-08-02T08:49:31.018028873Z 0 23046
2021-08-02T08:49:31.034310053Z 0 23046如您所见，有许多空值。左列更有可能为空，而字段键voltage的最右边列从来没有空值。
因此，我猜:同一行中的字段值对应于相同的时间戳，但它们不是同时写入数据库的，有些可能是写入的，而另一些则不是。是那么回事吗？
如果有一种方法让不同的字段在相同的raw中同时写入？，所以当我查询同一行中的每个字段时，都不是null。
或者如何查询最近一个所有字段都不是空的点？我实际上想查询度量中的最后一点：select * from "udp".."/controller/data" order by time desc limit 1，但是有时它会返回一个带空值的字段的点。
我发现last()帮不了我的忙。因为如果我使用SELECT last(*) FROM "udp".."/controller" WHERE time > now() - 1s(我使用WHERE子句，因为我认为它可以通过指定一个时间范围让它查询得更快)，它只是将来自last(angular)、last(speed_left_rear)、last(speed_right_rear)、last(voltage)的结果合并到一个点上。但是，字段值可能不会对相同的时间戳作出共同响应。
环境信息：
我所有这些程序都是在一个类似于raspberryPi的嵌入装置纳米粒子上运行的。
- 系统信息:Linux4.4.179 aarch64
- InfluxDB版本: 1.8.7
Config: my influx.conf
[[udp]]
enabled = true
batch-size = 50
batch-pending = 5
batch-timeout = "1s"我试着修改UDP批处理大小，看看它是否有任何不同：
如果我在influxdb.conf中将批处理大小修改为1
[[udp]]
enabled = true
batch-size = 1
batch-pending = 5
batch-timeout = "1s"它会增加大量的CPU负载，而我只能得到时间>现在-22秒的点。
select * from "udp".."/controller/data" where time >= now() - 22s并返回以下结果：
> SELECT * FROM "udp".."/controller/data" WHERE time >= now() - 21s
name: /controller/data
time angular speed_left_rear speed_right_rear voltage
---- ------- --------------- ---------------- -------
1627894525069581596 599 0 0 23276
1627894525115397757 366 0 0 23116
1627894525147390263 782 0 0 23258
1627894525163375140 216 0 0 23258
1627894525179457142 449 0 0 23258
1627894525211368273 249 0 0 23382
1627894525227548857 532 0 0 23382
1627894525259374239 133 0 0 23382
1627894525275378367 249 0 0 23169
1627894525307387789 665 0 0 23169
1627894525323413499 499 0 0 23169
1627894525355366338 599 0 0 23311
1627894525371388841 382 0 0 23311
1627894525387508467 499 0 0 23311
1627894525403456887 1148 0 0 23223
1627894525420205921 549 0 0 23205
1627894525436119925 149 0 0 23205
1627894525452726045 366 0 0 23205
1627894525468630132 183 0 0 23223
1627894525484748008 -99 0 0 23223
1627894525500814260 249 0 0 23223
1627894525516629098 499 0 0 23223
1627894525533157344 848 0 0 23205
1627894525548644353 366 0 0 23205
1627894525564793437 16 0 0 23205
1627894525627496298 66 0 0 23347
1627894525675488264 83 0 0 23240
1627894525723471189 -33 0 0 23418
1627894525755489652 166 0 0 23418
1627894525772796929 332 0 0 23418
1627894525803355328 23152它有时仍然返回一个空值。因此，更改批处理大小不适用于这个问题，而且似乎批处理大小是一个列的属性，它会打包一定数量的列数据，然后写入数据库。
回答 1
Stack Overflow用户
发布于 2021-08-11 08:22:26
我不会使用InfluxDB来处理来自最后500 to的数据。这个软件不适合这样的解决方案。InfluxDB没有优先级将所有值放在定义的时间内。这不是一个实时系统。如果你需要这样的东西，我建议PLC类型的设备，是实时的。但是..。如果您想这么多地使用它，我可以建议采用以下棘手的解决方案：
- 请求不更新的数据，例如400 is：
从“udp”.“/控制器/数据”中选择time >= now() -10 s和time<=now()-400 10s中的最后(*)
假设在400 in之后，您在所有字段中都有值。3)要求有安全延迟的数据，例如500毫秒：
从“udp”.“/控制器/数据”中选择time >= now() -500 now中的第一个(*)
从现在开始，以上查询应该在500 now之前给出第一个值。假设在略低于500 is的情况下，需要编写所有字段值。
- 使用where为所有值字段请求数据，如果只有数据，则总是正确的：
从“udp”.“/控制器/数据”中选择时间>= now() - 5s和“转角”>-9999999和"speed_left_rear">-9999999和“speed_right_rear”>-9999999“和”电压“的限制为1的*
以上假设您不能读取低于-9999999的值。通过这种方式，您应该只接收包含所有值且不大于5s的系列。您将得到的值是最新的，具有与所编写的所有值相同的时间戳。
- 2)解决方案在某些假定延迟的情况下可以工作，也可以不工作(取决于系统工作负载等)。3)如果您需要具有相同时间戳的值，则可能是最好的解决方案。
- 另一种方法是进行4个独立的查询，在其中查询最后一个值：
从“udp”.“/控制器/数据”选择最后(Speed_left_rear)从“udp”.“/控制器/数据”从“udp”中选择最后一次(Speed_right_rear).“/控制器/数据”从“udp”中选择最后(电压)
- 甚至在子查询中请求它：
选择* FROM (选择最后(角)作为“角”从“udp”.“/控制器/数据”选择最后(Speed_left_rear)为"speed_left_rear“从”udp“.”/控制器/数据“选择最后(Speed_right_rear)为"speed_right_rear”，(从“udp”选择最后(电压)为“电压”.“/控制器/数据”)
它会给出最新的值，但它们可能没有相同的时间戳。
https://stackoverflow.com/questions/68619027
复制相似问题
领取专属 10元无门槛券
AI混元助手 在线答疑
洞察 腾讯核心技术
剖析业界实践案例
腾讯云开发者
