RousselTMLEARNING

Article · Opentelemetry : de la découverte à l'expertise

Connecteurs, extensions et observabilité du Collector

1. Les connecteurs #

Faire passer des données d'un pipeline à un autre.

Principe #

Connecteur spanmetrics
Les métriques RED (débit, erreurs, durée) sont calculées à partir de 100 % des spans, avant l'échantillonnage.

Un connecteur est déclaré comme exportateur d'un pipeline et comme receiver d'un autre. Il permet de transformer un signal en un autre, de router ou de dupliquer des données.

Les plus utiles #

ConnecteurRôle
spanmetricscalcule débit, erreurs et durées (histogrammes) par service et opération à partir des spans
servicegraphproduit les métriques de la carte des dépendances entre services
countcompte des spans, logs ou points de métrique répondant à une condition OTTL
routingenvoie les données vers des pipelines différents selon un attribut (locataire, environnement)
failoverbascule vers un pipeline de secours si le principal échoue
forwardrelie simplement deux pipelines du même type
connectors:
  spanmetrics:
    histogram: { explicit: { buckets: [5ms, 25ms, 100ms, 250ms, 1s, 5s] } }
    dimensions: [{ name: http.request.method }, { name: http.response.status_code }]
  routing:
    default_pipelines: [logs/standard]
    table:
      - condition: resource.attributes["tenant"] == "premium"
        pipelines: [logs/premium]
service:
  pipelines:
    traces:          { receivers: [otlp], processors: [batch], exporters: [otlp/tempo, spanmetrics] }
    metrics/spans:   { receivers: [spanmetrics], exporters: [prometheusremotewrite] }
Bonne Pratique : Placez spanmetrics avant tout échantillonnage par la queue (tail sampling) : les métriques restent exactes même si vous ne gardez que 10 % des traces.

2. Les extensions #

Ce qui n'est pas dans le flux de données.

Panorama #

ExtensionUsage
health_checkpoint de santé HTTP pour les sondes Kubernetes et les répartiteurs de charge
pprofprofilage du Collector lui-même
zpagespages de diagnostic en direct (pipelines, spans récents)
file_storagestockage sur disque pour la file d'attente persistante et les positions de lecture des fichiers
bearertokenauth, oauth2client, basicauthauthentification auprès des backends ou des clients
opamppilotage à distance du Collector (voir Bindplane)
extensions:
  health_check: { endpoint: 0.0.0.0:13133 }
  zpages: { endpoint: 0.0.0.0:55679 }
  file_storage: { directory: /var/lib/otelcol/queue }
exporters:
  otlp/backend:
    endpoint: backend:4317
    sending_queue: { enabled: true, storage: file_storage }   # survit à un redémarrage
service:
  extensions: [health_check, zpages, file_storage]

3. Observer le Collector #

Il faut superviser le superviseur.

Télémétrie interne #

Le Collector expose ses propres métriques (par défaut au format Prometheus sur le port 8888) et peut envoyer ses logs et traces internes en OTLP. Trois questions à surveiller : reçoit-il ? perd-il ? sature-t-il ?

MétriqueSignale
otelcol_receiver_accepted_spans / _refused_spansdonnées acceptées ou refusées à l'entrée
otelcol_processor_dropped_*, refus du memory_limiterdonnées perdues par manque de mémoire
otelcol_exporter_sent_* / _send_failed_*envois réussis ou en échec vers le backend
otelcol_exporter_queue_size / _queue_capacityfile d'attente qui se remplit : backend trop lent ou injoignable
service:
  telemetry:
    logs: { level: info }
    metrics:
      level: detailed
      readers:
        - pull: { exporter: { prometheus: { host: 0.0.0.0, port: 8888 } } }
Erreur Courante : Une alerte sur otelcol_exporter_send_failed_* et sur le remplissage de la file vaut mieux que de découvrir un trou de plusieurs heures dans les traces pendant un incident.

4. Distributions et Collector sur mesure #

Ne livrer que les composants utiles.

Choisir #

DistributionContenu
otelcol (core)composants essentiels, maintenus par le projet
otelcol-contribdes centaines de composants communautaires : idéal pour tester
otelcol-k8ssélection adaptée à Kubernetes
Distributions éditeursGrafana Alloy, Bindplane BDOT, Splunk, Elastic EDOT, AWS ADOT…
# builder-config.yaml pour ocb (OpenTelemetry Collector Builder)
dist: { name: otelcol-maison, output_path: ./dist }
receivers:  [{ gomod: go.opentelemetry.io/collector/receiver/otlpreceiver v0.115.0 }]
processors: [{ gomod: go.opentelemetry.io/collector/processor/batchprocessor v0.115.0 }]
exporters:  [{ gomod: go.opentelemetry.io/collector/exporter/otlpexporter v0.115.0 }]
Bonne Pratique : En production, construisez une distribution avec ocb qui ne contient que vos composants : binaire plus petit, surface d'attaque réduite, mises à jour maîtrisées. Alignez les numéros de version de tous les modules.

📄 Collector OpenTelemetry : connecteurs, extensions et observabilité du Collector →

Mon suivi

  • ⏱ Durée estimée : ≈ 8 min

Connectez-vous pour suivre votre progression et prendre des notes. Se connecter

✉️ Poser une question

Articles recommandés

Prometheus dans le monde Kubernetes (Operator, ServiceMonitor, kube-prometheus-stack)

Superviser Kubernetes avec Prometheus : service discovery, kube-prometheus-stack, Prometheus Oper...

Grafana : maîtriser les requêtes (PromQL, LogQL, SQL et expressions)

Construire des requêtes efficaces dans Grafana : éditeur de requêtes, Query Inspector, PromQL, Lo...

Grafana Cloud : démarrer avec la plateforme managée (Mimir, Loki, Tempo, Alloy)

Découvrir Grafana Cloud : création d'une stack, offre gratuite, envoi de métriques, logs et trace...

OpenTelemetry Collector : les Processors (transformer, filtrer et protéger la télémétrie)

Maîtriser les processors du Collector OpenTelemetry : batch, memory_limiter, attributes, resource...

OpenTelemetry Collector : les Exporters (envoyer la télémétrie vers les backends)

Configurer les exporters du Collector OpenTelemetry : OTLP gRPC/HTTP, Prometheus, prometheusremot...

Tracing distribué : la propagation du contexte (W3C Trace Context et baggage)

Comprendre et mettre en œuvre la propagation de contexte OpenTelemetry : en-tête traceparent, tra...

Beats : aller plus loin (sécurité, performances, Elastic Agent et migration vers Alloy)

Industrialiser Filebeat, Metricbeat et les autres Beats : sorties sécurisées, processors, modules...

Dynatrace : gérer les permissions (IAM, groupes, politiques et périmètres)

Gérer les accès dans Dynatrace : modèle IAM (utilisateurs, groupes, politiques, périmètres/bounda...

Grafana Tempo : le backend de traces distribuées à grande échelle

Comprendre le tracing distribué et Grafana Tempo : traces, spans, TraceID, architecture (distribu...