Skip to content

Commit da318a6

Browse files
Add Sampling for Logs (#151)
1 parent 966deb6 commit da318a6

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

src/main/java/org/prebid/cache/handlers/cache/CacheHandler.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -70,14 +70,12 @@ Mono<ServerResponse> finalizeResult(final Mono<ServerResponse> mono,
7070
private Mono<ServerResponse> handleErrorMetrics(final Throwable error, final ServerRequest request) {
7171
if (error instanceof RepositoryException) {
7272
recordMetric(MeasurementTag.ERROR_DB);
73-
} else if (error instanceof ResourceNotFoundException) {
73+
} else if (error instanceof ResourceNotFoundException || error instanceof BadRequestException) {
7474
conditionalLogger.info(
7575
error.getMessage()
7676
+ ". Refererring URLs: " + request.headers().header(HttpHeaders.REFERER)
7777
+ ". Request URI: " + request.uri(),
7878
samplingRate);
79-
} else if (error instanceof BadRequestException) {
80-
log.error(error.getMessage());
8179
} else if (error instanceof TimeoutException) {
8280
metricsRecorder.markMeterForTag(this.metricTagPrefix, MeasurementTag.ERROR_TIMED_OUT);
8381
} else if (error instanceof DataBufferLimitException) {
@@ -86,8 +84,9 @@ private Mono<ServerResponse> handleErrorMetrics(final Throwable error, final Ser
8684
"Request length: `" + contentLength + "` exceeds maximum size limit",
8785
samplingRate);
8886
} else {
89-
log.error("Error occurred while processing the request: '{}', cause: '{}'",
90-
ExceptionUtils.getMessage(error), ExceptionUtils.getMessage(error));
87+
conditionalLogger.error("Error occurred while processing the request: '%s', cause: '%s'".formatted(
88+
ExceptionUtils.getMessage(error), ExceptionUtils.getMessage(error)),
89+
samplingRate);
9190
}
9291

9392
return builder.error(Mono.just(error), request)

0 commit comments

Comments
 (0)