1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2021 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Telemetry.Logger do
6 @moduledoc "Transforms Pleroma telemetry events to logs"
11 [:pleroma, :repo, :query]
14 :telemetry.attach_many(
17 &Pleroma.Telemetry.Logger.handle_event/4,
22 # Passing anonymous functions instead of strings to logger is intentional,
23 # that way strings won't be concatenated if the message is going to be thrown
24 # out anyway due to higher log level configured
27 [:pleroma, :repo, :query] = _name,
28 %{query_time: query_time} = measurements,
29 %{source: source} = metadata,
32 logging_config = Pleroma.Config.get([:telemetry, :slow_queries_logging], [])
34 if logging_config[:enabled] &&
35 logging_config[:min_duration] &&
36 query_time > logging_config[:min_duration] and
37 (is_nil(logging_config[:exclude_sources]) or
38 source not in logging_config[:exclude_sources]) do
39 log_slow_query(measurements, metadata, config)
46 %{query_time: query_time} = _measurements,
47 %{source: _source, query: query, params: query_params, repo: repo} = _metadata,
51 with {:ok, %{rows: explain_result_rows}} <-
52 repo.query("EXPLAIN " <> query, query_params, log: false) do
53 Enum.map_join(explain_result_rows, "\n", & &1)
56 {:current_stacktrace, stacktrace} = Process.info(self(), :current_stacktrace)
59 Enum.filter(stacktrace, fn
60 {__MODULE__, _, _, _} ->
66 |> String.starts_with?("Elixir.Pleroma.")
73 Total time: #{round(query_time / 1_000)} ms
77 #{inspect(query_params, limit: :infinity)}
81 #{Exception.format_stacktrace(pleroma_stacktrace)}