feat: clean more key types

segateway · Sep 25, 2023 · 4d20141 · 4d20141
1 parent 2a95d86
commit 4d20141
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/microsoft_azure_eventhub_source/_CleanEvent.py b/microsoft_azure_eventhub_source/_CleanEvent.py
@@ -19,13 +19,12 @@ def CleanEvent(source_dict: dict):
             if value.endswith("\n"):
                 value = value.strip("\n")
 
-            if value.startswith('{"'):
-                try:
-                    value = orjson.loads(value)
-                    CleanEvent(value)
-                    source_dict[key] = value
-                except orjson.JSONDecodeError:
-                    pass
+            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):