Skip to content

Commit 500e41d

Browse files
More concise
1 parent d1c662e commit 500e41d

File tree

1 file changed

+10
-16
lines changed
  • instrumentation/opentelemetry-instrumentation-aiohttp-server/src/opentelemetry/instrumentation/aiohttp_server

1 file changed

+10
-16
lines changed

instrumentation/opentelemetry-instrumentation-aiohttp-server/src/opentelemetry/instrumentation/aiohttp_server/__init__.py

Lines changed: 10 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,6 @@ async def hello(request):
150150

151151
from __future__ import annotations
152152

153-
import urllib
154153
from timeit import default_timer
155154

156155
from aiohttp import web
@@ -302,27 +301,22 @@ def collect_request_attributes(
302301
if port:
303302
_set_http_net_host_port(result, port, sem_conv_opt_in_mode)
304303

305-
path = request.path
306-
query_string = request.query_string
307-
target = path
308-
if query_string:
309-
target = f"{path}?{query_string}"
310-
if target:
311-
redacted_target = redact_query_parameters(target)
304+
if request.path_qs:
305+
redacted_target = redact_query_parameters(request.path_qs)
312306
_, redacted_query = _parse_url_query(redacted_target)
313307
_set_http_target(
314-
result, redacted_target, path, redacted_query, sem_conv_opt_in_mode
308+
result,
309+
redacted_target,
310+
request.path,
311+
redacted_query,
312+
sem_conv_opt_in_mode,
315313
)
316314

317315
# old semconv v1.20.0 - always set HTTP_URL when reporting old semconv
318316
if _report_old(sem_conv_opt_in_mode):
319-
http_url = str(request.url)
320-
if query_string:
321-
http_url += "?" + urllib.parse.unquote(query_string)
322-
result[HTTP_URL] = redact_url(http_url)
317+
result[HTTP_URL] = redact_url(str(request.url))
323318

324-
user_agent = request.headers.get("user-agent")
325-
if user_agent:
319+
if user_agent := request.headers.get("user-agent"):
326320
_set_http_user_agent(result, user_agent, sem_conv_opt_in_mode)
327321

328322
flavor = f"{request.version.major}.{request.version.minor}"
@@ -576,7 +570,7 @@ def _instrument(self, **kwargs):
576570
explicit_bucket_boundaries_advisory=HTTP_DURATION_HISTOGRAM_BUCKETS_NEW,
577571
)
578572

579-
meter_for_counter = meter_new if meter_new else meter_old
573+
meter_for_counter = meter_new or meter_old
580574
active_requests_counter = meter_for_counter.create_up_down_counter(
581575
name=MetricInstruments.HTTP_SERVER_ACTIVE_REQUESTS,
582576
unit="{request}",

0 commit comments

Comments
 (0)