feat(bigquery): add url.full attribute to span tracing (#12176)

This PR adds the url.full attribute to span tracing. It redacts any
credentials from the url itself, including query params using a
predefined set of key words standardized by rust
[here](https://github.com/googleapis/google-cloud-rust/blob/main/src/gax-internal/src/observability/http_tracing.rs#L28).

[example trace](https://screenshot.googleplex.com/o5W9GdWgsoruxNj.png)

---------

Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>

Author: ldetmer

java-bigquery/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/telemetry/HttpTracingRequestInitializer.java

@@ -52,6 +52,10 @@ public class HttpTracingRequestInitializer implements HttpRequestInitializer {
 
   @VisibleForTesting static final String HTTP_RPC_SYSTEM_NAME = "http";
 
+  private static final java.util.Set<String> REDACTED_QUERY_PARAMETERS =
+      com.google.common.collect.ImmutableSet.of(
+          "AWSAccessKeyId", "Signature", "sig", "X-Goog-Signature", "upload_id");
+
   private final HttpRequestInitializer delegate;
   private final Tracer tracer;
 
@@ -74,9 +78,7 @@ public void initialize(HttpRequest request) throws IOException {
       // No active span to exists, skip instrumentation
       return;
     }
-    String host = request.getUrl().getHost();
-    int port = request.getUrl().getPort();
-    addInitialHttpAttributesToSpan(span, host, port);
+    addInitialHttpAttributesToSpan(span, request);
 
     HttpResponseInterceptor originalInterceptor = request.getResponseInterceptor();
     request.setResponseInterceptor(
@@ -99,14 +101,16 @@ public void initialize(HttpRequest request) throws IOException {
   }
 
   /** Add initial HTTP attributes to the existing active span */
-  private void addInitialHttpAttributesToSpan(Span span, String host, Integer port) {
+  private void addInitialHttpAttributesToSpan(Span span, HttpRequest request) {
     BigQueryTelemetryTracer.addCommonAttributeToSpan(span);
     span.setAttribute(BigQueryTelemetryTracer.RPC_SYSTEM_NAME, HTTP_RPC_SYSTEM_NAME);
+    String host = request.getUrl().getHost();
     span.setAttribute(BigQueryTelemetryTracer.SERVER_ADDRESS, host);
-    if (port != null && port > 0) {
-      span.setAttribute(BigQueryTelemetryTracer.SERVER_PORT, port.longValue());
+    int port = request.getUrl().getPort();
+    if (port > 0) {
+      span.setAttribute(BigQueryTelemetryTracer.SERVER_PORT, (long) port);
     }
-    // TODO add full sanitized url, url domain, request method
+    span.setAttribute(URL_FULL, getSanitizedUrl(request));
   }
 
   private static void addCommonResponseAttributesToSpan(
@@ -136,4 +140,20 @@ static void addResponseBodySizeToSpan(HttpResponse response, Span span) {
     }
     // TODO handle chunked responses
   }
+
+  /** Removes credentials from URL. */
+  private static String getSanitizedUrl(HttpRequest request) {
+    GenericUrl clone = request.getUrl().clone();
+    // redact credentials sent as part of the address
+    if (clone.getUserInfo() != null) {
+      clone.setUserInfo("REDACTED:REDACTED");
+    }
+    // redact credentials passed as query params
+    for (String key : clone.keySet()) {
+      if (REDACTED_QUERY_PARAMETERS.contains(key)) {
+        clone.put(key, "REDACTED");
+      }
+    }
+    return clone.build();
+  }
 }

java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/telemetry/HttpTracingRequestInitializerTest.java

@@ -17,7 +17,9 @@
 package com.google.cloud.bigquery.telemetry;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.anyBoolean;
 import static org.mockito.Mockito.mock;
@@ -201,6 +203,49 @@ public void testUnsuccessfulResponseHandlerSetsErrorIfNoOriginal() throws IOExce
     closeAndVerifySpanData(401, "GET", -1, -1);
   }
 
+  @Test
+  public void testUrlQueryParametersAreRedacted() throws IOException {
+    HttpTransport transport = createTransport();
+    String urlWithQuery = BASE_URL + "?upload_id=secret_id&Signature=secret_sig&keep_me=ok";
+    HttpRequest request = buildGetRequest(transport, initializer, urlWithQuery);
+
+    HttpResponse response = request.execute();
+    response.disconnect();
+
+    spanScope.close();
+    parentSpan.end();
+
+    List<SpanData> spans = spanExporter.getFinishedSpanItems();
+    assertEquals(1, spans.size());
+    SpanData span = spans.get(0);
+    String urlFull = span.getAttributes().get(HttpTracingRequestInitializer.URL_FULL);
+
+    assertTrue(urlFull.contains("upload_id=REDACTED"));
+    assertTrue(urlFull.contains("Signature=REDACTED"));
+    assertTrue(urlFull.contains("keep_me=ok"));
+  }
+
+  @Test
+  public void testUrlCredentialsAreRedacted() throws IOException {
+    HttpTransport transport = createTransport();
+    String credUrl = "https://user:pass@bigquery.googleapis.com/bigquery/v2/projects/test/datasets";
+    HttpRequest request = buildGetRequest(transport, initializer, credUrl);
+
+    HttpResponse response = request.execute();
+    response.disconnect();
+
+    spanScope.close();
+    parentSpan.end();
+
+    List<SpanData> spans = spanExporter.getFinishedSpanItems();
+    assertEquals(1, spans.size());
+    SpanData span = spans.get(0);
+    String urlFull = span.getAttributes().get(HttpTracingRequestInitializer.URL_FULL);
+
+    assertFalse(urlFull.contains("user:pass"));
+    assertTrue(urlFull.contains("REDACTED:REDACTED@"));
+  }
+
   @Test
   public void testAddRequestBodySizeToSpan_ExceptionHandled() throws IOException {
     HttpContent content = mock(HttpContent.class);
@@ -369,6 +414,7 @@ private void closeAndVerifySpanData(
         Version.VERSION, span.getAttributes().get(BigQueryTelemetryTracer.GCP_CLIENT_VERSION));
     assertEquals(
         method, span.getAttributes().get(HttpTracingRequestInitializer.HTTP_REQUEST_METHOD));
+    assertEquals(BASE_URL, span.getAttributes().get(HttpTracingRequestInitializer.URL_FULL));
     if (requestBodySize >= 0) {
       assertEquals(
           requestBodySize,