csharp 通过SensorSerial和时间从表/扇出中清除InfluxDB读取数据。

Posted 2021-05-12

private async Task DeleteReadings()
{
  IList<string> serials = new List<string>()
  {
      "000D6F0004D0CB62",
      "000D6F0004D0CCC2",
      "000D6F0004D0C8F1",
      "000D6F0004D0CA7A",
      "000D6F0004D0CD2E",
      "000D6F0004D0CDD8",
      "000D6F0004D0C2BB",
      "000D6F0004D0C4D0",
      "000D6F0004D0E21D",
      "000D6F0004D0C8AA",
      "000D6F0004D0CE81",
      "000D6F0004D0D167",
      "000D6F0004D0C20F",
      "000D6F0004D0C723",
      "000D6F0004D0D0F6",
      "000D6F0004D0CA27",
      "000D6F0004D0D2E5",
      "000D6F0004D0C574"
  };

  foreach (var serial in serials)
  {
      _influxDbClient.QueryAsync(_influxDbName, String.Format("delete from reading.{0} where time < '2015-06-23 23:59:59.999'", serial), TimeUnit.Milliseconds);
      _influxDbClient.QueryAsync(_influxDbName, String.Format("delete from 30s.reading.{0} where time < '2015-06-23 23:59:59.999'", serial), TimeUnit.Milliseconds);
      _influxDbClient.QueryAsync(_influxDbName, String.Format("delete from 1m.reading.{0} where time < '2015-06-23 23:59:59.999'", serial), TimeUnit.Milliseconds);
      _influxDbClient.QueryAsync(_influxDbName, String.Format("delete from 5m.reading.{0} where time < '2015-06-23 23:59:59.999'", serial), TimeUnit.Milliseconds);
      _influxDbClient.QueryAsync(_influxDbName, String.Format("delete from 1h.reading.{0} where time < '2015-06-23 23:59:59.999'", serial), TimeUnit.Milliseconds);
      _influxDbClient.QueryAsync(_influxDbName, String.Format("delete from 1d.reading.{0} where time < '2015-06-23 23:59:59.999'", serial), TimeUnit.Milliseconds);
      _influxDbClient.QueryAsync(_influxDbName, String.Format("delete from 1w.reading.{0} where time < '2015-06-23 23:59:59.999'", serial), TimeUnit.Milliseconds);
  }
}