feat(tortoiseorm): replace db.statement.parameters with db.query.parameter.<key>

tortoiseorm has its own parameter capture implementation independent of
dbapi. Update it to use the shared `db_query_parameter_attributes` helper
and emit individual `db.query.parameter.<key>` attributes.

Author: Lotram

instrumentation/opentelemetry-instrumentation-tortoiseorm/src/opentelemetry/instrumentation/tortoiseorm/__init__.py

@@ -49,6 +49,7 @@
 from opentelemetry.instrumentation.tortoiseorm.package import _instruments
 from opentelemetry.instrumentation.tortoiseorm.version import __version__
 from opentelemetry.instrumentation.utils import (
+    db_query_parameter_attributes,
     is_instrumentation_enabled,
     unwrap,
 )
@@ -268,7 +269,9 @@ def _hydrate_span_from_args(self, connection, query, parameters) -> dict:
 
         if self.capture_parameters:
             if parameters is not None and len(parameters) > 0:
-                span_attributes["db.statement.parameters"] = str(parameters)
+                span_attributes.update(
+                    db_query_parameter_attributes(parameters)
+                )
 
         return span_attributes
 
@@ -286,7 +289,7 @@ async def _do_execute(self, func, instance, args, kwargs):
                 span_attributes = self._hydrate_span_from_args(
                     instance,
                     args[0],
-                    args[1:],
+                    args[1] if len(args) > 1 else None,
                 )
                 for attribute, value in span_attributes.items():
                     span.set_attribute(attribute, value)

instrumentation/opentelemetry-instrumentation-tortoiseorm/tests/test_tortoiseorm_instrumentation.py

@@ -21,6 +21,7 @@
 from opentelemetry.instrumentation.utils import suppress_instrumentation
 from opentelemetry.semconv._incubating.attributes.db_attributes import (
     DB_NAME,
+    DB_QUERY_PARAMETER_TEMPLATE,
     DB_STATEMENT,
     DB_SYSTEM,
 )
@@ -30,6 +31,7 @@
 class MockModel(models.Model):
     id = fields.IntField(pk=True)
     name = fields.TextField()
+    description = fields.TextField(default="")
 
     def __str__(self):
         return self.name
@@ -87,15 +89,35 @@ def test_capture_parameters(self):
 
         async def run():
             await self._init_tortoise()
-            await MockModel.create(name="Test Parameterized")
+            await MockModel.create(
+                name="Test Capture Params", description="Multiple Params"
+            )
 
         self._async_call(run())
         spans = self.memory_exporter.get_finished_spans()
         insert_span = next(s for s in spans if s.name == "INSERT")
-        self.assertIn("db.statement.parameters", insert_span.attributes)
-        self.assertIn(
-            "Test Parameterized",
-            insert_span.attributes["db.statement.parameters"],
+        self.assertEqual(
+            insert_span.attributes[f"{DB_QUERY_PARAMETER_TEMPLATE}.0"],
+            "'Test Capture Params'",
+        )
+        self.assertEqual(
+            insert_span.attributes[f"{DB_QUERY_PARAMETER_TEMPLATE}.1"],
+            "'Multiple Params'",
+        )
+
+    def test_capture_no_parameters(self):
+        TortoiseORMInstrumentor().uninstrument()
+        TortoiseORMInstrumentor().instrument(capture_parameters=True)
+
+        async def run():
+            await self._init_tortoise()
+            await MockModel.all()
+
+        self._async_call(run())
+        spans = self.memory_exporter.get_finished_spans()
+        select_span = next(s for s in spans if s.name == "SELECT")
+        self.assertNotIn(
+            f"{DB_QUERY_PARAMETER_TEMPLATE}.0", select_span.attributes
         )
 
     def test_uninstrument(self):