Procesadores de canalizaciones de métricas

Los procesadores de canalizaciones de métricas transforman los puntos de datos de las métricas de OTel durante la ingesta. Una canalización de métricas puede tener hasta 20 procesadores, que se aplican de forma secuencial en el orden en que se definen.

Los procesadores utilizan expresiones de ruta de OTTL para dirigirse a atributos de distintos ámbitos:

Procesador add_attributes

Agrega o sobrescribe atributos en los puntos de datos de las métricas. Funciona con todos los tipos de temporalidad.

Equivalente de OTTL: set(attributes["key"], "value")

Configuración

Configure el procesador add_attributes con los siguientes parámetros:

processor:
  - add_attributes:
      attributes:
        - key: resource.attributes["team"]
          value: "payments"
        - key: attributes["environment"]
          value: "production"
        - key: instrumentation_scope.attributes["version"]
          value: "1.0"
          overwrite_if_key_exists: true

Procesador delete_attributes

Elimina atributos específicos de los puntos de datos de las métricas. No se aplica a las métricas acumulativas ni a las métricas suministradas.

Equivalente de OTTL: delete_key(attributes, "key")

Configuración

Configure el procesador delete_attributes con los siguientes parámetros:

processor:
  - delete_attributes:
      with_keys:
        - resource.attributes["obsolete"]
        - attributes["temp"]
        - datapoint.attributes["debug"]

Procesador rename_attributes

Cambia el nombre de las claves de atributos en los puntos de datos de las métricas. No se aplica a las métricas acumulativas ni a las métricas suministradas.

Equivalente de OTTL: set() + delete_key()

Configuración

Configure el procesador rename_attributes con los siguientes parámetros:

processor:
  - rename_attributes:
      attributes:
        - from_key: resource.attributes["old_key"]
          to_key: resource.attributes["new_key"]
          overwrite_if_to_key_exists: true

Procesador rename_metrics

Cambia el nombre de las métricas. No se aplica a las métricas acumulativas ni a las métricas suministradas.

Equivalente de OTTL: set(name, "new.metric.name") where name == "old.metric.name"

Configuración

Configure el procesador rename_metrics con los siguientes parámetros:

processor:
  - rename_metrics:
      metrics:
        - from: "old.metric.name"
          to: "new.metric.name"

Procesador substitute_attribute_values

Asigna valores de atributos mediante una tabla de búsqueda. No se aplica a las métricas acumulativas ni a las métricas suministradas.

Equivalente de OTTL: replace_match()

Configuración

Configure el procesador substitute_attribute_values con los siguientes parámetros:

processor:
  - substitute_attribute_values:
      attributes:
        - key: resource.attributes["region"]
          from: "us-east-1a"
          to: "us-east-1"

Ejemplo completo

En el siguiente ejemplo se utilizan los cinco procesadores en una única canalización:

pipeline:
  source:
    cloudwatch_metrics:
      format: otlp
      selection_criteria:
        - match_all:
            - 'resource.attributes["service.name"] == "my-service"'
            - 'metric.name == "CPUUtilization"'
  processor:
    - add_attributes:
        attributes:
          - key: resource.attributes["env"]
            value: "prod"
            overwrite_if_key_exists: true
    - delete_attributes:
        with_keys:
          - resource.attributes["internal.trace"]
    - rename_attributes:
        attributes:
          - from_key: resource.attributes["old_key"]
            to_key: resource.attributes["new_key"]
    - rename_metrics:
        metrics:
          - from: "CPUUtilization"
            to: "system.cpu.utilization"
    - substitute_attribute_values:
        attributes:
          - key: resource.attributes["environment"]
            from: "dev"
            to: "development"
  sink:
    - cloudwatch_metrics: {}

Compatibilidad y restricciones de procesadores