写入操作
更新时间：2022-07-19
写入单域数据点
用户可以参考如下代码写入单域数据点：
注意：当写入的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));