Correct error in encode_parquet()

wazuh · Feb 6, 2024 · 6ac3c99 · 6ac3c99
1 parent 288c40a
commit 6ac3c99
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/integrations/stdin_to_securitylake.py b/integrations/stdin_to_securitylake.py
@@ -7,13 +7,13 @@
 import time
 import json
 from datetime import datetime
-from pyarrow import json, parquet, Table
+from pyarrow import parquet, Table
 
 chunk_ending = { "chunk_ending": True }
 
 def encode_parquet(list):
   table = Table.from_pylist(list)
-  pq.write_table(table, '/tmp/{}.parquet'.format(clockstr))
+  parquet.write_table(table, '/tmp/{}.parquet'.format(clockstr))
 
 def push_to_s3(parquet):
   ## Fill with AWS S3 code