feat: clean more key types

bamcs · Sep 25, 2023 · 74ce835 · 74ce835
1 parent 3ca5b40
commit 74ce835
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/microsoft_azure_eventhub_source/_CleanEvent.py b/microsoft_azure_eventhub_source/_CleanEvent.py
@@ -19,12 +19,13 @@ def CleanEvent(source_dict: dict):
             if value.endswith("\n"):
                 value = value.strip("\n")
 
-            try:
-                value = orjson.loads(value)
-                CleanEvent(value)
-                source_dict[key] = value
-            except orjson.JSONDecodeError:
-                pass
+            if value.startswith('{"') or value.startswith("[{"):
+                try:
+                    value = orjson.loads(value)
+                    CleanEvent(value)
+                    source_dict[key] = value
+                except orjson.JSONDecodeError:
+                    pass
         elif isinstance(value, dict) and not value:
             del source_dict[key]
         elif isinstance(value, dict):