国产精品免费嫩草研究院|无遮羞动漫在线观看AV|国产麻豆精品传媒AV国产在线|村在线观看|寂寞情人1正版|韩国床震韩国床震古|精品系列专区久久

  1. 首頁 > 生活 > >

influxDB2.2( 四 )

生活百科influxDB2.2

配置類@Data@ConfigurationProperties(prefix = "influxdb")@Componentpublic class InfluxdbConfigProp {  private String token;  private String bucket;  private String org;  private String url;}@Configurationpublic class InfluxdbConfig {  @Autowired private InfluxdbConfigProp influxdbConfigProp;  @Bean  public InfluxDBClient influxDBClient() {    InfluxDBClient influxClient =        InfluxDBClientFactory.create(            influxdbConfigProp.getUrl(), influxdbConfigProp.getToken().toCharArray());    influxClient.setLogLevel(LogLevel.BASIC);    return influxClient;  }  @Bean  public WriteApi writeApi(InfluxDBClient influxDBClient) {    WriteOptions writeOptions =        WriteOptions.builder()            .batchSize(5000)            .flushInterval(1000)            .bufferLimit(10000)            .jitterInterval(1000)            .retryInterval(5000)            .build();    return influxDBClient.getWriteApi(writeOptions);  }  @Bean  public QueryApi queryApi(InfluxDBClient influxDBClient) {    return influxDBClient.getQueryApi();  }}常用函數window()使用window()函數根據時間界限對數據進行分組 。window()傳遞的最常用參數是every，它定義了窗口之間的持續時間 。也可以使用其他參數，但是對于本例，將基本數據集窗口化為一分鐘窗口 。dataSet     |> window(every: 1m)
first()和last()【influxDB2.2】獲取查詢結果的第一條或最后一條
drop()刪除查詢結果的指定列|> drop(columns: ["host"])
sort()和limit()排序和分頁|> sort(columns: ["index", "time"], desc: true)|> limit(n: 10)n參數為pageSize
timedMovingAverage()對于表中的每一行，timedMovingAverage()返回當前值和上一個周期(持續時間)中所有行值的平均值 。它以每個參數定義的頻率返回移動平均線 。|> timedMovingAverage(every: 1h, period: 1h)
aggregateWindow()|> aggregateWindow(every: 1h, fn: first, createEmpty: true)每一小時時間片的第一條記錄，空數據以null填充
map()|> map( fn:(r) => {    return {      code: r["code"],      time: r["_time"],      value: r["_value"],      index: r["indexName"]      }   }  )注意事項

  • tag與tag之間用逗號分隔
  • field與field之間用逗號分隔
  • tag與field之間用空格分隔
  • tag都是string類型，不需要引號將value包裹
  • tag的值不能有空格
  • 寫入數據時，若tag和時間戳都相同的多條記錄，則最后只會保存一條

經驗總結擴展閱讀