Test_Project_Web/e5
1
0
Fork 0
mirror of https://github.com/luoye663/e5.git synced 2025-10-31 03:15:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

backup

Browse Source
This commit is contained in:
Luoye_W
2021-08-04 17:53:55 +08:00
parent 65b2ca6d6e
commit 605e90dbb3
2 changed files with 48 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/io/qyi/e5/bean/influx2/InfluxdbConfig.java
View File

@@ -21,4 +21,5 @@ public class InfluxdbConfig {
return influxDBClient;
}
}

48
src/main/java/io/qyi/e5/outlook_log/controller/OutlookLogController.java
View File

@@ -3,10 +3,13 @@ package io.qyi.e5.outlook_log.controller;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.QueryApi;
import com.influxdb.client.WriteApi;
import com.influxdb.client.WriteOptions;
import com.influxdb.client.domain.WritePrecision;
import com.influxdb.client.write.Point;
import com.influxdb.query.FluxRecord;
import com.influxdb.query.FluxTable;
import io.qyi.e5.bean.result.Result;
import io.qyi.e5.config.security.UsernamePasswordAuthenticationToken;
import io.qyi.e5.outlook.service.IOutlookService;
@@ -102,7 +105,6 @@ public class OutlookLogController {
}
try (WriteApi writeApi = influxDBClient.getWriteApi()) {
// writeApi.writePoint(bucket, org, point);
writeApi.writePoints(bucket,org, arrayList);
@@ -110,4 +112,48 @@ public class OutlookLogController {
return "ok";
}
@GetMapping("/find")
public void find(){
String flux = "from(bucket:\"e5\") |> range(start: 0)" +
"|> filter(fn: (r) => r[\"_measurement\"] == \"e5s\")" +
// "|> filter(fn: (r) => r[\"_field\"] == \"aaaaaa1\")" +
"|> limit(n: 100)";
QueryApi queryApi = influxDBClient.getQueryApi();
List<FluxTable> tables = queryApi.query(flux,org);
for (FluxTable fluxTable : tables) {
List<FluxRecord> records = fluxTable.getRecords();
for (FluxRecord fluxRecord : records) {
System.out.println(fluxRecord.getField());
System.out.println(fluxRecord.getTime() + " ->" + fluxRecord.getValueByKey("_value"));
}
}
/*queryApi.query(flux,org,(cancellable, fluxRecord) -> {
//
// The callback to consume a FluxRecord.
//
// cancelable - object has the cancel method to stop asynchronous query
//
System.out.println(fluxRecord.getTime() + ": " + fluxRecord.getValueByKey("_value"));
}, throwable -> {
//
// The callback to consume any error notification.
//
System.out.println("Error occurred: " + throwable.getMessage());
}, () -> {
//
// The callback to consume a notification about successfully end of stream.
//
System.out.println("Query completed");
});*/
}
}