leftover bulk index

tomrade · Oct 11, 2020 · 3ad9fca · 3ad9fca
1 parent e915151
commit 3ad9fca
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/nom.py b/lib/nom.py
@@ -258,6 +258,8 @@ def ingest_file(self,filename):
                 self.send_to_hec(events)
                 bulk = 0
                 events = []
+        if bulk != 0:
+            self.send_to_hec(events)
         end = datetime.datetime.utcnow()
         duration = end - start
         print("Finished Processing {} in {} seconds. ingested {} out of {} events".format(filename,duration.seconds,done - errors, done))