Differences

This shows you the differences between two versions of the page.

--- linux:influxdb [2024/02/22 02:07] – [Influxdb queries] admin
+++ linux:influxdb [2024/02/22 03:34] (current) – [InfluxDb] admin
@@ Line 1: / Line 1: @@
 ====== InfluxDb ======
 cheat sheet / examples https://www.sqlpac.com/en/documents/influxdb-flux-language-advanced-features.html#influxdb-v2-quick-reminders \\
+https://www.influxdata.com/blog/top-5-hurdles-for-flux-beginners-and-resources-for-learning-to-use-flux/ \\
 <WRAP left tip 200px>
 influxdb 3
@@ Line 47: / Line 48: @@
 //   |> drop(columns: ["host"])
 //   |> aggregateWindow(every: v.windowPeriod, fn: last, createEmpty: false)
+</code>
 ++++ Fields|
@@ Line 72: / Line 74: @@
 version
 ++++
+++++ TMP flux|
+<code SQL>
+import "influxdata/influxdb/schema"
+from(bucket: "sensors")
+//   |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
+  |> range(start: 2024-02-22T01:00:00Z, stop: 2024-02-22T10:00:00Z)
+  |> filter(fn: (r) => r["_measurement"] == "netflow")
+  |> filter(fn: (r) => r["host"] == "gorkii21")
+  |> filter(fn: (r) => r._field == "direction" or r._field == "dst" or r._field == "in_bytes" or r._field == "in_snmp" or r._field == "out_snmp" or r._field == "in_packets")
+  |> schema.fieldsAsCols()
+  // |> filter(fn: (r) => r["direction"] == "ingress")
+   |> filter(fn: (r) => r["dst"] == "192.168.114.109")
+   |> duplicate(column: "in_bytes", as: "_value")
+//  |> duplicate(column: "in_packets", as: "_value")
+  |> duplicate(column: "dst", as: "_measurement")
+    |> group(columns: ["_measurement","_start","in_snmp","out_snmp","direction"])
+   |> aggregateWindow(every: 10m,  fn: sum, createEmpty: true)
+//   |> group(columns: ["dst"])
+//   |> sum()
+//   |> group()
+//   |>top(n: 10)
+//   |>sort(columns: ["_value"])
+//   |>yield()
+//
+//
+//
+//   |> sum()
+//   |> yield()
+//
+//   |> drop(columns: ["host"])
+//   |> aggregateWindow(every: v.windowPeriod, fn: last, createEmpty: false)
 </code>
+++++