Fix sanitization for bulk queries

open-telemetry · Oct 6, 2023 · 5e576df · 5e576df
1 parent 7ac6744
commit 5e576df
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...ry-instrumentation-elasticsearch/src/opentelemetry/instrumentation/elasticsearch/utils.py b/...ry-instrumentation-elasticsearch/src/opentelemetry/instrumentation/elasticsearch/utils.py
@@ -52,9 +52,15 @@ def _unflatten_dict(d):
 
 
 def sanitize_body(body) -> str:
+    if isinstance(body, bytes):
+        body = body.decode("utf8")
+
     if isinstance(body, str):
         body = json.loads(body)
 
+    if isinstance(body, list):
+        return str([sanitize_body(elem) for elem in body])
+
     flatten_body = _flatten_dict(body)
 
     for key in flatten_body: