Merge pull request #419 from metrico/filter_nan

filter nan values on ingestion
metrico · Jan 2, 2024 · 8ff76c2 · 8ff76c2
2 parents 819bda4 + 1ba932a
commit 8ff76c2
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/lib/handlers/influx_write.js b/lib/handlers/influx_write.js
@@ -108,6 +108,9 @@ async function handler (req, res) {
             asyncLogError('no bulkable data', req.log)
             return res.code(204).send('')
           }
+          if (typeof value === 'number' && isNaN(value)) {
+            return
+          }
           const values = [
             finger,
             BigInt(pad('0000000000000000000', timestamp, true)),
@@ -116,7 +119,7 @@ async function handler (req, res) {
           ]
           bulk.add([values])
         }
-      /* logs or syslog */
+        /* logs or syslog */
       } else if (stream.measurement === 'syslog' || JSONFields.message) {
         // Send fields as a JSON object for qryn to parse
         // const message = JSON.stringify(JSONFields)

diff --git a/lib/handlers/prom_push.js b/lib/handlers/prom_push.js
@@ -59,6 +59,9 @@ async function handler (req, res) {
               asyncLogError({ entry }, req.log)
               return
             }
+            if (isNaN(entry.value)) {
+              return
+            }
             const ts = BigInt(entry.timestamp)
             const values = [
               finger,