From 51d8eb3751973e414362fc3ddfd1740bcf412be0 Mon Sep 17 00:00:00 2001 From: Giorgio Trettenero Date: Mon, 9 Dec 2024 15:46:29 -0800 Subject: [PATCH] Record caller metrics in Atlas comment out: Record caller metrics in Atlas original adding UNKNOWN value print print without call print without call and double print still print but uncomment first put still print and uncomment second put still print and uncomment both puts focus only on first call, which errors, and use log instead of print assign to variable logs around variable logs around variable don't directly print null remove logs --- .../com/netflix/metacat/common/MetacatRequestContext.java | 3 ++- .../java/com/netflix/metacat/main/api/RequestWrapper.java | 7 +++++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/metacat-common/src/main/java/com/netflix/metacat/common/MetacatRequestContext.java b/metacat-common/src/main/java/com/netflix/metacat/common/MetacatRequestContext.java index 7f28875d2..1efb31d02 100644 --- a/metacat-common/src/main/java/com/netflix/metacat/common/MetacatRequestContext.java +++ b/metacat-common/src/main/java/com/netflix/metacat/common/MetacatRequestContext.java @@ -92,7 +92,7 @@ public class MetacatRequestContext implements Serializable { */ public MetacatRequestContext() { this.userName = null; - this.clientAppName = null; + this.clientAppName = UNKNOWN; this.clientId = null; this.jobId = null; this.dataTypeContext = null; @@ -198,6 +198,7 @@ public static class MetacatRequestContextBuilder { MetacatRequestContextBuilder() { this.bApiUri = UNKNOWN; this.bScheme = UNKNOWN; + this.bClientAppName = UNKNOWN; } /** diff --git a/metacat-main/src/main/java/com/netflix/metacat/main/api/RequestWrapper.java b/metacat-main/src/main/java/com/netflix/metacat/main/api/RequestWrapper.java index 23240b85d..64f28c003 100644 --- a/metacat-main/src/main/java/com/netflix/metacat/main/api/RequestWrapper.java +++ b/metacat-main/src/main/java/com/netflix/metacat/main/api/RequestWrapper.java @@ -154,8 +154,14 @@ public R processRequest( if (requestTags != null) { tags.putAll(requestTags); } + tags.put("request", resourceRequestName); tags.put("scheme", MetacatContextManager.getContext().getScheme()); + String clientAppName = MetacatContextManager.getContext().getClientAppName(); + if (clientAppName == null) { + clientAppName = "UNKNOWN"; + } + tags.put("caller", clientAppName); registry.counter(requestCounterId.withTags(tags)).increment(); try { @@ -243,6 +249,7 @@ public R processRequest( final long start = registry.clock().wallTime(); final Map tags = Maps.newHashMap(); tags.put("request", resourceRequestName); + tags.put("caller", MetacatContextManager.getContext().getClientAppName()); registry.counter(requestCounterId.withTags(tags)).increment(); try { MetacatContextManager.getContext().setRequestName(resourceRequestName);