Przeglądaj źródła

Avoid deprecated influxdb api

Nick Babcock 2 lat temu
rodzic
commit
3a15ba7d72
2 zmienionych plików z 4 dodań i 4 usunięć
  1. 3 3
      OhmGraphite.Test/InfluxTest.cs
  2. 1 1
      OhmGraphite/Influx2Writer.cs

+ 3 - 3
OhmGraphite.Test/InfluxTest.cs

@@ -131,7 +131,7 @@ namespace OhmGraphite.Test
                 try
                 try
                 {
                 {
                     await writer.ReportMetrics(DateTime.Now, TestSensorCreator.Values());
                     await writer.ReportMetrics(DateTime.Now, TestSensorCreator.Values());
-                    var influxDBClient = InfluxDBClientFactory.Create(options);
+                    var influxDBClient = new InfluxDBClient(options);
                     var flux = "from(bucket:\"mydb\") |> range(start: -1h)";
                     var flux = "from(bucket:\"mydb\") |> range(start: -1h)";
                     var queryApi = influxDBClient.GetQueryApi();
                     var queryApi = influxDBClient.GetQueryApi();
                     var tables = await queryApi.QueryAsync(flux, "myorg");
                     var tables = await queryApi.QueryAsync(flux, "myorg");
@@ -182,7 +182,7 @@ namespace OhmGraphite.Test
                 try
                 try
                 {
                 {
                     await writer.ReportMetrics(DateTime.Now, TestSensorCreator.Values());
                     await writer.ReportMetrics(DateTime.Now, TestSensorCreator.Values());
-                    var influxDBClient = InfluxDBClientFactory.Create(results.Influx2.Options);
+                    var influxDBClient = new InfluxDBClient(results.Influx2.Options);
                     var flux = "from(bucket:\"mydb\") |> range(start: -1h)";
                     var flux = "from(bucket:\"mydb\") |> range(start: -1h)";
                     var queryApi = influxDBClient.GetQueryApi();
                     var queryApi = influxDBClient.GetQueryApi();
                     var tables = await queryApi.QueryAsync(flux, "myorg");
                     var tables = await queryApi.QueryAsync(flux, "myorg");
@@ -251,7 +251,7 @@ namespace OhmGraphite.Test
                     try
                     try
                     {
                     {
                         await writer.ReportMetrics(DateTime.Now, TestSensorCreator.Values());
                         await writer.ReportMetrics(DateTime.Now, TestSensorCreator.Values());
-                        var influxDbClient = InfluxDBClientFactory.Create(results.Influx2.Options);
+                        var influxDbClient = new InfluxDBClient(results.Influx2.Options);
                         var flux = "from(bucket:\"mydb\") |> range(start: -1h)";
                         var flux = "from(bucket:\"mydb\") |> range(start: -1h)";
                         var queryApi = influxDbClient.GetQueryApi();
                         var queryApi = influxDbClient.GetQueryApi();
                         var tables = await queryApi.QueryAsync(flux, "myorg");
                         var tables = await queryApi.QueryAsync(flux, "myorg");

+ 1 - 1
OhmGraphite/Influx2Writer.cs

@@ -24,7 +24,7 @@ namespace OhmGraphite
 
 
         public async Task ReportMetrics(DateTime reportTime, IEnumerable<ReportedValue> sensors)
         public async Task ReportMetrics(DateTime reportTime, IEnumerable<ReportedValue> sensors)
         {
         {
-            var influxDbClient = InfluxDBClientFactory.Create(_config.Options);
+            var influxDbClient = new InfluxDBClient(_config.Options);
             var writeApi = influxDbClient.GetWriteApiAsync();
             var writeApi = influxDbClient.GetWriteApiAsync();
             var points = sensors.Select(x => NewPoint(reportTime, x)).ToList();
             var points = sensors.Select(x => NewPoint(reportTime, x)).ToList();
             await writeApi.WritePointsAsync(points);
             await writeApi.WritePointsAsync(points);