搜索本产品文档关键词
写入操作
所有文档
menu

时序时空数据库 TSDB

写入操作

写入单域数据点

用户可以参考如下代码写入单域数据点:

注意:当写入的metric、field、tags、timestamp都相同时,后写入的value会覆盖先写入的value。

Plain Text
1String METRIC = "wind";                                            // metric
2String TAG_KEY = "city";                                           // 标签名称
3String TAG_VALUE = "ShangHai";                                     // 标签值
4String FIELD = "direction";                                        // 域
5 
6// 创建数据点
7List<Datapoint> datapoints = Arrays.asList(new Datapoint()
8                .withMetric(METRIC)                                  // 设置Metric
9                .withField(FIELD)                                    // 设置数据点域,可选,不填使用默认域名 value
10                .addTag(TAG_KEY, TAG_VALUE)                          // 设置Tag
11                .addDoubleValue(System.currentTimeMillis(), 0.1));   // 添加一个数据点
12 
13 
14tsdbClient.writeDatapoints(datapoints);

一个Datapoint对象可以同时添加多个数据点,这些数据点使用相同的metric和标签,相同的域。多个相同metric和标签的数据放入同一个Datapoint对象,可以减少payload。

Plain Text
1Datapoint datapoint = new Datapoint()
2              .withMetric(METRIC)                                      // 设置Metric
3              .withField(FIELD)                                        // 设置数据点域,可选,不填使用默认域名 value
4              .addTag(TAG_KEY, TAG_VALUE)                              // 设置Tag
5              .addDoubleValue(System.currentTimeMillis(), 0.1)         // 添加一个数据点
6              .addDoubleValue(System.currentTimeMillis() + 1, 0.2);    // 再添加一个数据点

Datapoint对象可以添加double,long和String类型的数据点。对于同一个field,如果写入了某个数据类型的value之后,相同的field不允许写入其他数据类型。

Plain Text
1// 添加Double类型数据点
2Datapoint datapoint1 = new Datapoint()
3              .withMetric("wind")                                     // 设置Metric
4              .withField(FIELD)                                       // 设置数据点域,可选,不填使用默认域名 value
5              .addTag(TAG_KEY, TAG_VALUE)                             // 设置Tag
6              .addDoubleValue(System.currentTimeMillis(), 0.1);       // 添加Double类型数据点
7 
8// 添加Long类型数据点
9Datapoint datapoint2 = new Datapoint()
10              .withMetric("temperature")                              // 设置Metric
11              .addTag(TAG_KEY, TAG_VALUE)                             // 设置Tag
12              .addLongValue(System.currentTimeMillis(), 10L);         // 添加Long类型数据点
13 
14// 添加String类型数据点
15Datapoint datapoint3 = new Datapoint()
16              .withMetric("humidity")                                 // 设置Metric
17              .addTag(TAG_KEY, TAG_VALUE)                             // 设置Tag
18              .addStringValue(System.currentTimeMillis(), "string");  // 添加String类型数据点
19              
20// 添加BigDecimal类型数据点
21Datapoint datapoint4 = new Datapoint()
22              .withMetric("metric")                                                        // 设置Metric
23              .addTag(TAG_KEY, TAG_VALUE)                                                  // 设置Tag
24              .addBigDecimalValue(System.currentTimeMillis(), BigDecimal.valueOf(1.234));  // 添加BigDecimal类型数据点                  

写入多域数据点

不同的域并不需要同时写入,可以认为不同的域都是独立的。但如果查询时要用一条语句查出来,需要保证metric、所有的tag、时间戳都是一致的。

可以参考以下代码写入多域数据点:

Plain Text
1String METRIC = "wind";                                              // metric
2String TAG_KEY = "city";                                             // 标签名称
3String TAG_VALUE = "ShangHai";                                       // 标签值
4String FIELD_1 = "direction";                                        // 域1
5String FIELD_2 = "speed";                                            // 域2
6long TIME = System.currentTimeMillis();                              // 时间
7
8// 添加FIELD_1的数据点
9Datapoint datapoint1 = new Datapoint()
10              .withMetric(METRIC)                                     // 设置Metric
11              .withField(FIELD_1)                                     // 设置域1
12              .addTag(TAG_KEY, TAG_VALUE)                             // 设置Tag
13              .addDoubleValue(TIME, 0.1);                             // 指定时间写入Double类型数据点
14
15// 添加FIELD_2的数据点
16Datapoint datapoint2 = new Datapoint()
17              .withMetric(METRIC)                                     // 设置Metric,需要和FIELD1的一样
18              .withField(FIELD_2)                                     // 设置域2      
19              .addTag(TAG_KEY, TAG_VALUE)                             // 设置Tag,需要和FIELD1的一样         
20              .addLongValue(TIME, 10L);                               // 指定时间添加Long类型数据点,时间需要和FIELD_1的一样
21tsdbClient.writeDatapoints(Arrays.asList(datapoint1, datapoint2));
上一篇
创建TsdbClient
下一篇
查询操作