OpenTelemetry MCP Server

Instructions

Implementation Reference

• src/tools/prometheus_tools.py:55-97 (handler)

  The implementation of the `query_prometheus_range` function in `prometheus_tools.py`. It handles range query execution, time parsing, and error reporting.

  async def query_prometheus_range(
      client: PrometheusClient,
      query: str,
      start: Optional[str] = None,
      end: Optional[str] = None,
      step: str = "15s"
  ) -> Dict[str, Any]:
      """
      Execute PromQL range query.
      
      Args:
          client: Prometheus client
          query: PromQL query string
          start: Start time (relative like '1h' or absolute)
          end: End time (relative like 'now' or absolute)
          step: Query resolution step
          
      Returns:
          Query results with time series data
      """
      try:
          # Parse time range
          start_dt, end_dt = parse_time_range(start, end)
          start_ts = to_prometheus_time(start_dt)
          end_ts = to_prometheus_time(end_dt)
          
          result = await client.query_range(query, start_ts, end_ts, step)
          
          return {
              "success": True,
              "query": query,
              "start": start or "auto",
              "end": end or "now",
              "step": step,
              "result": result
          }
      except Exception as e:
          logger.error(f"Error executing Prometheus range query: {e}")
          return {
              "success": False,
              "error": str(e),
              "query": query
          }