Packages
new_relic_agent
1.15.0-rc.3
1.40.3
1.40.2
1.40.1
1.40.0
1.39.0
1.38.0
1.37.0
1.36.0
1.35.0
1.34.0
1.33.0
1.32.0
1.31.1
1.31.0
1.30.0
1.29.0
1.28.0
1.27.8
1.27.7
1.27.6
1.27.5
1.27.4
1.27.3
1.27.2
1.27.1
1.27.0
1.26.0
1.25.3
1.25.2
1.25.1
1.25.0
1.24.5
1.24.4
1.24.3
1.24.2
1.24.1
1.24.0
1.24.0-rc.10
1.24.0-rc.9
1.24.0-rc.8
1.24.0-rc.7
1.23.6
1.23.5
1.23.4
1.23.3
1.23.2
1.23.1
1.23.0
1.23.0-rc.6
1.23.0-rc.5
1.23.0-rc.4
1.23.0-rc.3
1.23.0-rc.2
1.23.0-rc.1
1.22.6
1.22.5
1.22.4
1.22.3
1.22.2
1.22.1
1.22.0
1.21.2
1.21.1
1.21.0
1.21.0-rc.3
1.21.0-rc.1
1.20.0
1.20.0-rc.1
1.19.7
1.19.6
1.19.5
1.19.4
1.19.3
1.19.2
1.19.1
1.19.0
1.18.5
1.18.4
1.18.3
1.18.2
1.18.1
1.18.0
1.18.0-rc.5
1.18.0-rc.4
1.18.0-rc.2
1.18.0-rc.1
1.17.1
1.17.0
1.17.0-rc.4
1.17.0-rc.3
1.17.0-rc.2
1.17.0-rc.1
1.17.0-rc.0
1.16.7
1.16.6
1.16.5
1.16.4
1.16.3
1.16.2
1.16.1
1.16.0
1.16.0-rc.2
1.16.0-rc.1
1.16.0-rc.0
1.15.0
1.15.0-rc.3
1.15.0-rc.2
1.15.0-rc.1
1.14.0
1.13.1
1.13.0
1.12.0
1.11.0
1.10.2
1.10.1
1.10.0
1.9.12
1.9.11
1.9.10
1.9.9
1.9.8
1.9.7
1.9.6
1.9.5
1.9.4
1.9.3
1.9.2
1.9.1
1.9.0
1.8.0
1.7.0
1.6.2
1.6.1
1.6.0
1.5.0
1.4.0
1.3.2
1.3.1
1.3.0
1.2.1
1.2.0
1.1.0
1.0.5
1.0.4
1.0.3
1.0.2
1.0.1
1.0.0
New Relic's Open-Source Elixir Agent
Current section
Files
Jump to
Current section
Files
lib/new_relic/telemetry/ecto/handler.ex
defmodule NewRelic.Telemetry.Ecto.Handler do
def handle_event(
_event,
%{total_time: total_time} = measurements,
%{type: :ecto_sql_query, repo: repo} = metadata,
config
) do
end_time = System.system_time(:millisecond)
duration_ms = total_time |> to_ms
duration_s = duration_ms / 1000
start_time = end_time - duration_ms
query_time_ms = measurements[:query_time] |> to_ms
queue_time_ms = measurements[:queue_time] |> to_ms
decode_time_ms = measurements[:decode_time] |> to_ms
%{hostname: hostname, port: port, database: database} = config.repo_configs[repo]
query = (config.collect_sql? && metadata.query) || ""
pid = inspect(self())
id = {:ecto_sql_query, make_ref()}
parent_id = Process.get(:nr_current_span) || :root
with {datastore, table, operation} <- NewRelic.Telemetry.Ecto.Metadata.parse(metadata) do
metric_name = "Datastore/statement/#{datastore}/#{table}/#{operation}"
secondary_name = "#{inspect(repo)} #{hostname}:#{port}/#{database}"
NewRelic.Transaction.Reporter.add_trace_segment(%{
primary_name: metric_name,
secondary_name: secondary_name,
attributes: %{
sql: query,
collection: table,
operation: operation,
host: hostname,
database_name: database,
port_path_or_id: port |> to_string
},
pid: pid,
id: id,
parent_id: parent_id,
start_time: start_time,
end_time: end_time
})
NewRelic.report_span(
timestamp_ms: start_time,
duration_s: duration_s,
name: metric_name,
edge: [span: id, parent: parent_id],
category: "datastore",
attributes:
%{
component: datastore,
"span.kind": :client,
"db.statement": query,
"db.instance": database,
"peer.address": "#{hostname}:#{port}}",
"peer.hostname": hostname,
"db.table": table,
"db.operation": operation,
"ecto.repo": inspect(repo)
}
|> maybe_add("ecto.query_time.ms", query_time_ms)
|> maybe_add("ecto.queue_time.ms", queue_time_ms)
|> maybe_add("ecto.decode_time.ms", decode_time_ms)
)
NewRelic.report_metric(
{:datastore, datastore, table, operation},
duration_s: duration_s
)
NewRelic.incr_attributes(
databaseCallCount: 1,
databaseDuration: duration_s,
datastore_call_count: 1,
datastore_duration_ms: duration_ms,
"datastore.#{table}.call_count": 1,
"datastore.#{table}.duration_ms": duration_ms
)
end
end
def handle_event(_event, _value, _metadata, _config) do
:ignore
end
defp to_ms(nil), do: nil
defp to_ms(ns), do: System.convert_time_unit(ns, :nanosecond, :millisecond)
defp maybe_add(map, _, nil), do: map
defp maybe_add(map, key, value), do: Map.put(map, key, value)
end