55 lines
2.0 KiB
Java
55 lines
2.0 KiB
Java
import com.cnbm.influx.config.InfluxClient;
|
||
import com.cnbm.influx.template.Event;
|
||
import com.influxdb.client.InfluxDBClient;
|
||
import com.influxdb.client.InfluxDBClientFactory;
|
||
import com.influxdb.client.WriteApi;
|
||
import com.influxdb.client.domain.WritePrecision;
|
||
import com.influxdb.client.write.Point;
|
||
|
||
import java.time.Instant;
|
||
import java.util.ArrayList;
|
||
import java.util.List;
|
||
|
||
/**
|
||
* @Desc: ""
|
||
* @Author: caixiang
|
||
* @DATE: 2022/7/1 16:39
|
||
*/
|
||
public class Main2 {
|
||
public static void main(String[] args) {
|
||
//方式1
|
||
Point point = Point.measurement("ASProcessCompleteEvent")
|
||
.addTag("transationId", "112311")
|
||
.addTag("argName", "argName11")
|
||
.addField("argValue", 3D)
|
||
.time(Instant.now().toEpochMilli(), WritePrecision.MS);
|
||
InfluxClient.Client.getWriteApi().writePoint(point);
|
||
|
||
|
||
// //方式2
|
||
// char[] token = "lkBsC27QZr1W50BSPlGxpTqNNpwuUk5uz1dZZRPSPbCG5VmNDDUo8P3UkZIhGWwfJwkuz6ZGZ7Et4_KBaG3gHw==".toCharArray();
|
||
// String org = "qgs";
|
||
// String bucket = "mytest";
|
||
// InfluxDBClient influxDBClient = InfluxDBClientFactory.create("http://192.168.0.170:8086", token, org, bucket);
|
||
// WriteApi writeApi = influxDBClient.makeWriteApi();
|
||
// Point point = Point.measurement("ASProcessCompleteEvent")
|
||
// .addTag("transationId", "112311")
|
||
// .addTag("argName", "argName11")
|
||
// .addField("argValue", 7D)
|
||
// .time(Instant.now().toEpochMilli(), WritePrecision.MS);
|
||
//
|
||
//
|
||
// Point point2 = Point.measurement("ASProcessCompleteEvent")
|
||
// .addTag("transationId", "222312")
|
||
// .addTag("argName", "argName11")
|
||
// .addField("argValue", 8D)
|
||
// .time(Instant.now().toEpochMilli(), WritePrecision.MS);
|
||
// List<Point> list = new ArrayList<>();
|
||
// list.add(point);
|
||
// list.add(point2);
|
||
// writeApi.writePoints(list);
|
||
// //一定要close ，不如write 不了数据
|
||
// influxDBClient.close();
|
||
}
|
||
}
|