当前位置: 首页 > 知识库问答 >
问题:

带有influxdb-java的批点被覆盖,除非强制唯一时间?

汪博艺
2023-03-14
InfluxDB connection = InfluxDBFactory.connect(server, client);
connection.enableBatch(100,10,TimeUnit.MILLISECONDS);
connection.setDatabase(database);
BatchPoints batchPoints = BatchPoints.database(database).build();

long currTime = System.currentTimeMillis()*1000000;
double[] data1 = getInfluxData();
for (int i=someInt; i < data1.length; i++){
    if (i % someInt == 0){
        double[] data2 = processData(data1, i-someInt, i);
        for (int j=0; j < data2.length; j++){
            Point p = Point.measurement(someTable)
                .time(currTime+i+j, TimeUnit.NANOSECONDS)   //Line A (j < someInt)
                .tag("someTag", "someTagValue")
                .addField("someField", data2[j])
                .build();
            batchPoints.point(p)
        }
}
connection.write(batchPoints);
connection.disableBatch();
connection.close();

共有1个答案

康元凯
2023-03-14

在InfluxDB中,所有具有相同标记值和时间戳的点,即使具有不同的字段值,也被认为是重复的。因此这些数据点会被无人值守地覆盖。这与InfluxDB设计一致。

Is it a limitation of influx that only one point can exist with the same tags and timestamp?

是的,这是故意的。

If a collision does occur, does the old one get overwritten?

是的,它是静默覆盖的。

 类似资料:
  • 问题内容: 是否可以强制重命名os.rename覆盖另一个文件(如果已经存在)?例如,在下面的代码中,如果文件Tests.csv已经存在,则将其替换为Tests.txt文件(该文件也已重命名为Tests.csv)。 问题答案: 您可以尝试: 或然后:

  • 我仍在学习封装。我有一个,其中每个emcapsulated都有一个数组,以及它们的所有设置程序 现在在我的程序中,我注意到数组listRule(其中添加了与语法相关的规则)在每次添加新语法时都会被覆盖。我已经能够识别出错误发生在会清空listRule中所有其他语法的内容,因此listRule似乎对所有语法都是一样的。我的数组listRule创建不正确还是我的循环?

  • 我想推送我的本地文件,并将它们放在远程存储库上,而不必处理合并冲突。我只想让我的本地版本优先于远程版本。 我怎样才能用Git做到这一点?

  • 本文向大家介绍Python重新引入被覆盖的自带function,包括了Python重新引入被覆盖的自带function的使用技巧和注意事项,需要的朋友参考一下 幸运的是, 这一问题还是很容易解决的, 我们只需要使用__builtins__: 这样一来我们又可以重新使用python的int了, 但在此时叫做py_int. 一个function或变量的被覆盖最常见的原因是在引用时使用了"*": 当这样

  • 这是我的限制: 该查询证明约束实际上不起作用: 下面是输出: 为什么唯一性没有被强制执行?

  • 我正在使用Spring Boot 2.1.6.RELEASE,我想知道应该如何使用? 配置示例: 和位于不同的模块中。 错误: 无法注册在类路径资源[com/example/autoconf/configuration/app configuration . class]中定义的bean“foo”。已在类路径资源[com/my/configuration/myautoconfiguration .