La til telemetri

Author: naviktthomas

Diff for: jobs/arbeidssoekere-synk-jobb/build.gradle.kts

@@ -27,6 +27,10 @@ dependencies {
     implementation(libs.jackson.datatypeJsr310)
     implementation(libs.jackson.dataformat.csv)
 
+    // Instrumentation
+    implementation(libs.opentelemetry.api)
+    implementation(libs.opentelemetry.annotations)
+
     // Database
     implementation(libs.exposed.jdbc)
     implementation(libs.exposed.javaTime)

Diff for: jobs/arbeidssoekere-synk-jobb/nais/nais-dev.yaml

@@ -13,6 +13,13 @@ spec:
       memory: 256Mi
   secureLogs:
     enabled: true
+  observability:
+    autoInstrumentation:
+      enabled: true
+      runtime: java
+  azure:
+    application:
+      enabled: true
   filesFrom:
     - secret: paw-arbeidssoekere-synk-jobb-csv
       mountPath: /var/run/secrets/paw-arbeidssoekere-synk-jobb-csv

Diff for: jobs/arbeidssoekere-synk-jobb/src/main/kotlin/no/nav/paw/arbeidssoeker/synk/service/ArbeidssoekerSynkService.kt

@@ -1,6 +1,6 @@
 package no.nav.paw.arbeidssoeker.synk.service
 
-import io.ktor.http.isSuccess
+import io.opentelemetry.instrumentation.annotations.WithSpan
 import no.nav.paw.arbeidssoeker.synk.consumer.InngangHttpConsumer
 import no.nav.paw.arbeidssoeker.synk.model.VersjonertArbeidssoeker
 import no.nav.paw.arbeidssoeker.synk.model.asOpprettPeriodeRequest
@@ -9,6 +9,7 @@ import no.nav.paw.arbeidssoeker.synk.model.isNotSuccess
 import no.nav.paw.arbeidssoeker.synk.model.millisSince
 import no.nav.paw.arbeidssoeker.synk.repository.ArbeidssoekerSynkRepository
 import no.nav.paw.arbeidssoeker.synk.utils.ArbeidssoekerCsvReader
+import no.nav.paw.arbeidssoeker.synk.utils.traceAndLog
 import no.nav.paw.logging.logger.buildApplicationLogger
 import no.nav.paw.logging.logger.buildNamedLogger
 import java.nio.file.Path
@@ -22,6 +23,7 @@ class ArbeidssoekerSynkService(
     private val logger = buildApplicationLogger
     private val secureLogger = buildNamedLogger("secure")
 
+    @WithSpan(value = "synkArbeidssoekere")
     fun synkArbeidssoekere(path: Path) {
         var totalCount = 0
         val timestamp = Instant.now()
@@ -39,6 +41,7 @@ class ArbeidssoekerSynkService(
         logger.info("Fullførte prosessering av {} linjer CSV-data på {} ms", totalCount, timestamp.millisSince())
     }
 
+    @WithSpan(value = "prosesserArbeidssoeker")
     @Suppress("LoggingSimilarMessage")
     private fun prosesserArbeidssoeker(arbeidssoeker: VersjonertArbeidssoeker) {
         val (version, identitetsnummer) = arbeidssoeker
@@ -50,25 +53,15 @@ class ArbeidssoekerSynkService(
             logger.debug("Fant ingen status i databasen for version {}", version)
             logger.debug("Kaller API Inngang for opprettelse av periode")
             val response = inngangHttpConsumer.opprettPeriode(arbeidssoeker.asOpprettPeriodeRequest())
-            if (response.status.isSuccess()) {
-                logger.debug("Opprettelse av periode fullførte OK")
-            } else {
-                // TODO: Vurdere å ha en feilteller, og så avbryte om det blir for mange feil
-                logger.debug("Opprettelse av periode feilet med status {}", response.status.value)
-            }
+            logger.traceAndLog(response.status)
 
             logger.debug("Oppretter status {} i databasen for version {}", response.status.value, version)
             arbeidssoekerSynkRepository.insert(version, identitetsnummer, response.status.value)
         } else if (row.status.isNotSuccess()) {
             logger.debug("Fant feilet status {} i databasen for version {}", row.status, version)
             logger.debug("Utfører opprettelse av periode i registeret")
             val response = inngangHttpConsumer.opprettPeriode(arbeidssoeker.asOpprettPeriodeRequest())
-            if (response.status.isSuccess()) {
-                logger.debug("Opprettelse av periode i registeret fullførte OK")
-            } else {
-                // TODO: Vurdere å ha en feilteller, og så avbryte om det blir for mange feil
-                logger.debug("Opprettelse av periode i registeret feilet med status {}", response.status.value)
-            }
+            logger.traceAndLog(response.status)
 
             logger.debug("Oppdaterer status {} i databasen for version {}", response.status.value, version)
             arbeidssoekerSynkRepository.update(version, identitetsnummer, response.status.value)

Diff for: jobs/arbeidssoekere-synk-jobb/src/main/kotlin/no/nav/paw/arbeidssoeker/synk/utils/Logging.kt

@@ -0,0 +1,32 @@
+package no.nav.paw.arbeidssoeker.synk.utils
+
+import io.ktor.http.HttpStatusCode
+import io.ktor.http.isSuccess
+import io.opentelemetry.api.common.Attributes
+import io.opentelemetry.api.trace.Span
+import io.opentelemetry.api.trace.StatusCode
+import org.slf4j.Logger
+
+private fun attributes(status: HttpStatusCode): Attributes = Attributes.builder()
+    .put("domain", "perioder")
+    .put("action", "write")
+    .put("status", status.value.toString())
+    .build()
+
+fun Logger.traceAndLog(status: HttpStatusCode) {
+    with(Span.current()) {
+        val attributes = attributes(status)
+        if (status.isSuccess()) {
+            setAllAttributes(attributes)
+            addEvent("ok", attributes)
+            setStatus(StatusCode.OK)
+            debug("Opprettelse av periode fullførte OK")
+        } else {
+            // TODO: Vurdere å ha en feilteller, og så avbryte om det blir for mange feil
+            setAllAttributes(attributes)
+            addEvent("error", attributes)
+            setStatus(StatusCode.ERROR, status.toString())
+            debug("Opprettelse av periode feilet med status {}", status.value)
+        }
+    }
+}