如何在Elixir中使用OpenTelemetry的otel_resource_detector

步骤1：创建Elixir模块实现otel_resource_detector行为 #

直接调用Erlang的OpenTelemetry模块，用Elixir语法重写你的Erlang逻辑：

defmodule ExtraMetadata do
  @behaviour :otel_resource_detector

  @impl true
  def get_resource(_args) do
    # 处理第一个元数据文件
    resource1 =
      "/data/extrametadata.properties"
      |> get_metadata()
      |> :otel_resource_app_env.parse()
      |> :otel_resource.create([])

    # 处理第二个隐藏路径的元数据文件
    resource2 =
      with {:ok, hidden_content} <- :file.read_file("/data/hiddenpath.properties") do
        hidden_content
        |> get_metadata()
        |> :otel_resource_app_env.parse()
        |> :otel_resource.create([])
      else
        _error -> :otel_resource.create([])
      end

    # 合并两个资源
    :otel_resource.merge(resource1, resource2)
  end

  defp get_metadata(input) do
    try do
      content =
        case input do
          # 输入是文件路径时，读取文件内容
          path when is_binary(path) ->
            {:ok, content} = :file.read_file(path)
            content

          # 输入是已读取的二进制内容时直接使用
          content when is_binary(content) ->
            content
        end

      # 拆分每行并转换为键值对列表
      content
      |> String.split("\n", trim: true)
      |> Enum.reduce([], fn line, acc ->
        case String.split(line, "=", parts: 2) do
          [key, value] -> [{key, value} | acc]
          _invalid_line -> acc # 跳过格式错误的行
        end
      end)
    rescue
      _ -> [] # 异常时返回空列表，避免后续parse逻辑崩溃
    end
  end
end

步骤2：配置OpenTelemetry加载自定义检测器 #

在项目配置文件（如config/config.exs）中，将自定义检测器加入资源检测器列表：

config :opentelemetry,
  resource_detectors: [ExtraMetadata, :otel_resource_detector_env, :otel_resource_detector_os]

关键差异说明 #

• Elixir中引用Erlang模块需要加前缀冒号（如:otel_resource）
• 使用@behaviour :otel_resource_detector声明实现Erlang行为，并用@impl true标记行为实现函数
• 用with语句处理文件读取的成功/失败分支，替代Erlang的模式匹配绑定
• 用String.split/3替代Erlang的binary:split/3，添加parts:2确保值中包含=时不会被错误拆分
• 异常处理使用rescue捕获文件读取或解析错误，返回空列表而非字符串，符合:otel_resource_app_env.parse/1的输入要求

内容的提问来源于stack exchange，提问作者Juliano Costa