Merge pull request #169 from axiomhq/remove-ndjson

Author: toppercodes

pyproject.toml

@@ -11,7 +11,6 @@ dependencies = [
     "ujson>=5.10.0",
     "dacite>=1.8.1",
     "pyhumps>=3.8.0",
-    "ndjson>=0.3.1",
 ]
 license = { file = "LICENSE" }
 classifiers = [

src/axiom_py/client.py

@@ -1,6 +1,5 @@
 """Client provides an easy-to use client library to connect to Axiom."""
 
-import ndjson
 import atexit
 import gzip
 import ujson
@@ -254,8 +253,9 @@ def ingest_events(
         See https://axiom.co/docs/restapi/endpoints/ingestIntoDataset
         """
         # encode request payload to NDJSON
-        content = ndjson.dumps(
-            events, default=handle_json_serialization
+        content = "\n".join(
+            ujson.dumps(event, default=handle_json_serialization)
+            for event in events
         ).encode("UTF-8")
         gzipped = gzip.compress(content)
 

tests/test_client.py

@@ -197,7 +197,7 @@ def test_step005_apl_query_messages(self):
         self.assertEqual(len(qr.status.messages), 1)
         self.assertEqual(
             qr.status.messages[0].msg,
-            "line: 1, col: 24: where clause always evaluates to TRUE, which will include all data",
+            "where clause always evaluates to TRUE, which will include all data",
         )
         self.assertEqual(
             qr.status.messages[0].code,