Use semantic conventions

instrumentation/opentelemetry_ecto/lib/opentelemetry_ecto.ex

@@ -20,6 +20,8 @@ defmodule OpentelemetryEcto do
 
   require OpenTelemetry.Tracer
 
+  alias OpenTelemetry.SemConv.Incubating.DBAttributes
+
   @typedoc """
   Option that you can pass to `setup/2`.
   """
@@ -65,7 +67,7 @@ defmodule OpentelemetryEcto do
       this config will have precedence.
     * `:db_statement` - `:disabled` (default), `:enabled`, or a function.
       Whether or not to include DB statements in the **span attributes** (as the
-      `db.statement` attribute).
+      `#{DBAttributes.db_statement()}` attribute).
       Optionally provide a function that takes a query string and returns a
       sanitized version of it. This is useful for removing sensitive information from the
       query string. Unless this option is `:enabled` or a function,
@@ -124,12 +126,12 @@ defmodule OpentelemetryEcto do
     # TODO: need connection information to complete the required attributes
     # net.peer.name or net.peer.ip and net.peer.port
     base_attributes = %{
-      "db.type": db_type,
-      source: source,
-      "db.instance": database,
-      "db.name": database,
-      "db.url": url,
-      "total_time_#{time_unit}s": System.convert_time_unit(total_time, :native, time_unit)
+      :source => source,
+      :"db.instance" => database,
+      :"db.type" => db_type,
+      unquote(DBAttributes.db_name()) => database,
+      :"db.url" => url,
+      :"total_time_#{time_unit}s" => System.convert_time_unit(total_time, :native, time_unit)
     }
 
     db_statement_config = Keyword.get(config, :db_statement, :disabled)
@@ -202,35 +204,35 @@ defmodule OpentelemetryEcto do
   end
 
   defp maybe_add_db_statement(attributes, :enabled, query) do
-    Map.put(attributes, :"db.statement", query)
+    Map.put(attributes, unquote(DBAttributes.db_statement()), query)
   end
 
   defp maybe_add_db_statement(attributes, :disabled, _query) do
     attributes
   end
 
   defp maybe_add_db_statement(attributes, sanitizer, query) when is_function(sanitizer, 1) do
-    Map.put(attributes, :"db.statement", sanitizer.(query))
+    Map.put(attributes, unquote(DBAttributes.db_statement()), sanitizer.(query))
   end
 
   defp maybe_add_db_statement(attributes, _, _query) do
     attributes
   end
 
   defp maybe_add_db_system(attributes, Ecto.Adapters.Postgres) do
-    Map.put(attributes, :"db.system", :postgresql)
+    Map.put(attributes, unquote(DBAttributes.db_system()), :postgresql)
   end
 
   defp maybe_add_db_system(attributes, Ecto.Adapters.MyXQL) do
-    Map.put(attributes, :"db.system", :mysql)
+    Map.put(attributes, unquote(DBAttributes.db_system()), :mysql)
   end
 
   defp maybe_add_db_system(attributes, Ecto.Adapters.SQLite3) do
-    Map.put(attributes, :"db.system", :sqlite)
+    Map.put(attributes, unquote(DBAttributes.db_system()), :sqlite)
   end
 
   defp maybe_add_db_system(attributes, Ecto.Adapters.Tds) do
-    Map.put(attributes, :"db.system", :mssql)
+    Map.put(attributes, unquote(DBAttributes.db_system()), :mssql)
   end
 
   defp maybe_add_db_system(attributes, _) do

instrumentation/opentelemetry_ecto/mix.exs

@@ -59,6 +59,7 @@ defmodule OpentelemetryEcto.MixProject do
       {:telemetry, "~> 0.4 or ~> 1.0"},
       {:opentelemetry_api, "~> 1.4"},
       {:opentelemetry_process_propagator, "~> 0.3"},
+      {:opentelemetry_semantic_conventions, "~> 1.27"},
       {:opentelemetry, "~> 1.5", only: [:dev, :test]},
       {:opentelemetry_exporter, "~> 1.0", only: [:dev, :test]},
       {:ex_doc, "~> 0.36", only: [:dev], runtime: false},

instrumentation/opentelemetry_ecto/mix.lock

@@ -21,7 +21,7 @@
   "opentelemetry_api": {:hex, :opentelemetry_api, "1.4.0", "63ca1742f92f00059298f478048dfb826f4b20d49534493d6919a0db39b6db04", [:mix, :rebar3], [], "hexpm", "3dfbbfaa2c2ed3121c5c483162836c4f9027def469c41578af5ef32589fcfc58"},
   "opentelemetry_exporter": {:hex, :opentelemetry_exporter, "1.6.0", "f4fbf69aa9f1541b253813221b82b48a9863bc1570d8ecc517bc510c0d1d3d8c", [:rebar3], [{:grpcbox, ">= 0.0.0", [hex: :grpcbox, repo: "hexpm", optional: false]}, {:opentelemetry, "~> 1.3", [hex: :opentelemetry, repo: "hexpm", optional: false]}, {:opentelemetry_api, "~> 1.2", [hex: :opentelemetry_api, repo: "hexpm", optional: false]}, {:tls_certificate_check, "~> 1.18", [hex: :tls_certificate_check, repo: "hexpm", optional: false]}], "hexpm", "1802d1dca297e46f21e5832ecf843c451121e875f73f04db87355a6cb2ba1710"},
   "opentelemetry_process_propagator": {:hex, :opentelemetry_process_propagator, "0.3.0", "ef5b2059403a1e2b2d2c65914e6962e56371570b8c3ab5323d7a8d3444fb7f84", [:mix, :rebar3], [{:opentelemetry_api, "~> 1.0", [hex: :opentelemetry_api, repo: "hexpm", optional: false]}], "hexpm", "7243cb6de1523c473cba5b1aefa3f85e1ff8cc75d08f367104c1e11919c8c029"},
-  "opentelemetry_semantic_conventions": {:hex, :opentelemetry_semantic_conventions, "0.2.0", "b67fe459c2938fcab341cb0951c44860c62347c005ace1b50f8402576f241435", [:mix, :rebar3], [], "hexpm", "d61fa1f5639ee8668d74b527e6806e0503efc55a42db7b5f39939d84c07d6895"},
+  "opentelemetry_semantic_conventions": {:hex, :opentelemetry_semantic_conventions, "1.27.0", "acd0194a94a1e57d63da982ee9f4a9f88834ae0b31b0bd850815fe9be4bbb45f", [:mix, :rebar3], [], "hexpm", "9681ccaa24fd3d810b4461581717661fd85ff7019b082c2dff89c7d5b1fc2864"},
   "opentelemetry_telemetry": {:hex, :opentelemetry_telemetry, "1.1.2", "410ab4d76b0921f42dbccbe5a7c831b8125282850be649ee1f70050d3961118a", [:mix, :rebar3], [{:opentelemetry_api, "~> 1.3", [hex: :opentelemetry_api, repo: "hexpm", optional: false]}, {:telemetry, "~> 1.1", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "641ab469deb181957ac6d59bce6e1321d5fe2a56df444fc9c19afcad623ab253"},
   "postgrex": {:hex, :postgrex, "0.17.4", "5777781f80f53b7c431a001c8dad83ee167bcebcf3a793e3906efff680ab62b3", [:mix], [{:db_connection, "~> 2.1", [hex: :db_connection, repo: "hexpm", optional: false]}, {:decimal, "~> 1.5 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: true]}, {:table, "~> 0.1.0", [hex: :table, repo: "hexpm", optional: true]}], "hexpm", "6458f7d5b70652bc81c3ea759f91736c16a31be000f306d3c64bcdfe9a18b3cc"},
   "ssl_verify_fun": {:hex, :ssl_verify_fun, "1.1.7", "354c321cf377240c7b8716899e182ce4890c5938111a1296add3ec74cf1715df", [:make, :mix, :rebar3], [], "hexpm", "fe4c190e8f37401d30167c8c405eda19469f34577987c76dde613e838bbc67f8"},