RousselTMLEARNING

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

TP : Logs OpenTelemetry corrélés aux traces et collecte de fichiers

Ce que vous allez apprendre dans ce TP
  • Brancher un logger existant sur OpenTelemetry
  • Corréler logs et traces
  • Collecter des fichiers avec filelog

Introduction #

Ce que vous allez apprendre dans cette section
  • Brancher un logger existant sur OpenTelemetry
  • Corréler logs et traces
  • Collecter des fichiers avec filelog

Contexte. Les logs de facturation sont des fichiers texte que personne ne relie aux traces. Vous branchez le service moderne sur OpenTelemetry et récupérez les logs de l'application historique sans la modifier.

Prérequis : Docker et Python 3.10 ou plus ; la pile grafana/otel-lgtm (Collector, Tempo, Loki, Prometheus, Pyroscope et Grafana dans un seul conteneur)  ·  Durée estimée : 45 min

Des logs structurés, corrélés aux traces, issus des deux voies de collecte.

Mise en place #

Étapes guidées, avec leur correction.

  1. 1. Démarrer la pile d'observabilité

    Pourquoi ? Une seule image fournit un Collector OTLP et tous les backends : on se concentre sur le signal.

    Lancez grafana/otel-lgtm, créez un environnement Python et pointez les exportateurs vers le port OTLP/HTTP 4318.
  2. 2. Brancher le module logging

    Pourquoi ? Le LoggingHandler transforme chaque appel logging en LogRecord OpenTelemetry, avec le contexte de trace actif.

    Écrivez facturation.py : un LoggerProvider avec exportateur OTLP, un handler ajouté au logger racine, un TracerProvider, et des logs INFO et ERROR émis à l'intérieur de spans.
  3. 3. Interroger et corréler dans Grafana

    Pourquoi ? Le trace_id porté par chaque log permet de passer du log à la trace et inversement.

    Dans Explore > Loki, affichez les erreurs du service, dépliez une ligne et repérez trace_id, span_id, la sévérité et vos attributs. Ouvrez la trace liée, puis depuis un span Tempo affichez ses logs.
  4. 4. Collecter les logs d'une application historique

    Pourquoi ? Sans toucher au code, le receiver filelog lit les fichiers, parse le JSON, la sévérité et le contexte de trace.

    Générez un fichier de logs JSON, puis lancez un Collector contrib sur le même réseau que la pile, avec filelog, json_parser, trace_parser et un processeur resource qui fixe service.name.
  5. 5. Réduire et masquer

    Pourquoi ? Le Collector supprime le bruit et les données personnelles avant le stockage.

    Ajoutez un processeur filter qui supprime les logs INFO et un transform qui masque les adresses e-mail dans le corps, puis vérifiez dans Loki.

Niveau de difficulté : ●●●○○ (3/5)

Mon suivi

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

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

✉️ Poser une question

Articles recommandés

Sécurité et gouvernance Dynatrace : IAM avancé, politiques, SSO, audit et protection des données

Sécuriser et gouverner Dynatrace : SSO et SCIM, groupes, politiques IAM avec conditions, contexte...

Architecture distribuée Elasticsearch : rôles des nœuds, shards, répliques et allocation

Comprendre le fonctionnement distribué d'Elasticsearch : rôles des nœuds, nœuds master et quorum,...

Mappings et analyse de texte Elasticsearch : types de champs, analyseurs et mapping dynamique

Maîtriser les mappings Elasticsearch : types de champs (text, keyword, numériques, date, ip, nest...

Ingestion Elasticsearch : Bulk API, ingest pipelines, enrich et reindex

Ingérer et transformer des données dans Elasticsearch : Bulk API, ingest pipelines et processeurs...

Index Lifecycle Management (ILM) : data tiers, rollover et rétention

Automatiser le cycle de vie des index avec ILM : data tiers hot, warm, cold et frozen, rollover p...

Data streams et templates Elasticsearch : component templates, index templates et séries temporelles

Gérer les données horodatées avec les data streams : index templates et component templates, conv...

Query DSL et agrégations avancées Elasticsearch, avec ES|QL

Écrire des requêtes Elasticsearch avancées : bool, filter et score, nested, function_score et per...

Monitoring et troubleshooting Elasticsearch : santé, shards non assignés, JVM, hot threads et slow logs

Diagnostiquer un cluster Elasticsearch : cluster health et CAT APIs, shards non assignés et alloc...

Performance et capacity planning Elasticsearch : shards, heap, indexation et benchmarks

Dimensionner et optimiser Elasticsearch : taille et nombre de shards, heap JVM, caches, réglages ...