wip

Author: ykoer

.github/actions/log_to_splunk/main.py

@@ -120,8 +120,6 @@ def main():
         return
 
     z = zipfile.ZipFile(io.BytesIO(x.content))
-    # z.extractall('/app')
-    #log_folder = '/Users/ykoer/Workspace/ykoer/github-actions-example-workflows/.github/actions/log_to_splunk/tmp'
     log_folder = '/tmp'
     z.extractall(log_folder)
 
@@ -158,8 +156,6 @@ def main():
                     batch+=1
                     event={'event':x,'sourcetype':SPLUNK_SOURCETYPE,'source':SPLUNK_SOURCE,'host':host,'time':timestamp,'fields':fields}
                     eventBatch=eventBatch+json.dumps(event)
-                # else:
-                #     print("skipped line "+str(count))
 
                 # push every 1000 log lines to splunk as a batch
                 if batch>=1000:
@@ -174,11 +170,10 @@ def main():
 
         # push the last batch
         if batch>0:
-            print(f'log_file={name}, batch_number={batch_number}, line_number={count}')
-            # x=requests.post(SPLUNK_HEC_URL, data=eventBatch, headers=headers)
-            # print(f'log_file={name}, batch_number={batch_number}, line_number={count}, request_status_code:{x.status_code}')
+            # print(f'log_file={name}, batch_number={batch_number}, line_number={count}')
+            x=requests.post(SPLUNK_HEC_URL, data=eventBatch, headers=headers)
+            print(f'log_file={name}, batch_number={batch_number}, line_number={count}, request_status_code:{x.status_code}')
             eventBatch=""
-            batch_number+=1
 
 if __name__ == '__main__':
     main()