Azure
diff --git a/‎sdk/agentserver/azure-ai-agentserver-core/CHANGELOG.md‎
Lines changed: 7 additions & 0 deletions b/‎sdk/agentserver/azure-ai-agentserver-core/CHANGELOG.md‎
Lines changed: 7 additions & 0 deletions
diff --git a/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/__init__.py‎
Lines changed: 2 additions & 0 deletions b/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/__init__.py‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/_base.py‎
Lines changed: 69 additions & 2 deletions b/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/_base.py‎
Lines changed: 69 additions & 2 deletions
diff --git a/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/_config.py‎
Lines changed: 1 addition & 0 deletions b/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/_config.py‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/_middleware.py‎
Lines changed: 135 additions & 0 deletions b/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/_middleware.py‎
Lines changed: 135 additions & 0 deletions
diff --git a/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/_tracing.py‎
Lines changed: 9 additions & 4 deletions b/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/_tracing.py‎
Lines changed: 9 additions & 4 deletions
diff --git a/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/_version.py‎
Lines changed: 1 addition & 1 deletion b/‎sdk/agentserver/azure-ai-agentserver-core/azure/ai/agentserver/core/_version.py‎
Lines changed: 1 addition & 1 deletion
@@ -1,5 +1,12 @@
 # Release History
 
+## 2.0.0b2 (2026-04-17)
+
+### Features Added
+
+- Startup configuration logging — `AgentServerHost` lifespan now emits three INFO-level log lines at startup: platform environment (agent name, version, port, session ID, SSE keep-alive), connectivity (project endpoint and OTLP endpoint masked to scheme://host, Application Insights configured flag), and host options (shutdown timeout, registered protocols). Sensitive values (Application Insights connection string) are never logged.
+- `InboundRequestLoggingMiddleware` — pure-ASGI middleware wired automatically by `AgentServerHost` that logs every inbound HTTP request. Logs method, path (no query string), status code, duration in milliseconds, and correlation headers (`x-request-id`, `x-ms-client-request-id`). Status codes >= 400 are logged at WARNING; unhandled exceptions are logged as status 500 at WARNING. OpenTelemetry trace ID is included when an active trace exists.
+
 ## 2.0.0b1 (2026-04-14)
 
 This is a major architectural rewrite. The package has been redesigned as a lightweight hosting
 
@@ -26,6 +26,7 @@
 from ._base import AgentServerHost
 from ._config import AgentConfig
 from ._errors import create_error_response
+from ._middleware import InboundRequestLoggingMiddleware
 from ._server_version import build_server_version
 from ._tracing import (
     configure_observability,
@@ -41,6 +42,7 @@
 __all__ = [
     "AgentConfig",
     "AgentServerHost",
+    "InboundRequestLoggingMiddleware",
     "build_server_version",
     "configure_observability",
     "create_error_response",
 
@@ -6,7 +6,14 @@
 import logging
 import os
 import signal
-from collections.abc import AsyncGenerator, AsyncIterable, AsyncIterator, Awaitable, Callable  # pylint: disable=import-error
+import urllib.parse
+from collections.abc import (  # pylint: disable=import-error
+    AsyncGenerator,
+    AsyncIterable,
+    AsyncIterator,
+    Awaitable,
+    Callable,
+)
 from typing import Any, MutableMapping, Optional, Union
 
 from starlette.applications import Starlette
@@ -17,6 +24,7 @@
 from starlette.types import ASGIApp, Receive, Scope, Send
 
 from . import _config, _tracing
+from ._middleware import InboundRequestLoggingMiddleware
 from ._server_version import build_server_version
 from ._version import VERSION as _CORE_VERSION
 
@@ -25,6 +33,35 @@
 # Pre-built health-check response to avoid per-request allocation.
 _HEALTHY_BODY = b'{"status":"healthy"}'
 
+_NOT_SET = "(not set)"
+
+
+def _mask_uri(uri: str) -> str:
+    """Return only the scheme and host of a URI, hiding path/query/credentials.
+
+    Returns ``"(not set)"`` for empty or whitespace-only values, or
+    ``"(redacted)"`` when the URI cannot be parsed into scheme + host.
+
+    :param uri: The URI to mask.
+    :type uri: str
+    :return: ``"scheme://host[:port]"``, ``"(not set)"``, or ``"(redacted)"``.
+    :rtype: str
+    """
+    stripped = uri.strip() if uri else ""
+    if not stripped:
+        return _NOT_SET
+    try:
+        parsed = urllib.parse.urlparse(stripped)
+        scheme = parsed.scheme or ""
+        host = parsed.hostname or ""
+        if scheme and host:
+            port_suffix = f":{parsed.port}" if parsed.port else ""
+            return f"{scheme}://{host}{port_suffix}"
+        # Best-effort: if parsing fails to extract components, redact entirely
+        return "(redacted)"
+    except Exception:  # pylint: disable=broad-exception-caught
+        return "(redacted)"
+
 
 class _PlatformHeaderMiddleware:
     """Pure-ASGI middleware that adds ``x-platform-server`` header to responses.
@@ -176,6 +213,32 @@ def __init__(
         @contextlib.asynccontextmanager
         async def _lifespan(_app: Starlette) -> AsyncGenerator[None, None]:  # noqa: RUF029
             logger.info("AgentServerHost started")
+
+            # --- Startup configuration logging ---
+            cfg = self.config
+            logger.info(
+                "Platform environment: is_hosted=%s, agent_name=%s, agent_version=%s, "
+                "port=%s, session_id=%s, sse_keepalive_interval=%s",
+                cfg.is_hosted,
+                cfg.agent_name or _NOT_SET,
+                cfg.agent_version or _NOT_SET,
+                cfg.port,
+                cfg.session_id or _NOT_SET,
+                cfg.sse_keepalive_interval if cfg.sse_keepalive_interval > 0 else "disabled",
+            )
+            logger.info(
+                "Connectivity: project_endpoint=%s, otlp_endpoint=%s, appinsights_configured=%s",
+                _mask_uri(cfg.project_endpoint),
+                _mask_uri(cfg.otlp_endpoint),
+                bool(cfg.appinsights_connection_string),
+            )
+            protocols = ", ".join(self._server_version_segments) if self._server_version_segments else _NOT_SET
+            logger.info(
+                "Host options: shutdown_timeout=%ss, protocols=%s",
+                self._graceful_shutdown_timeout,
+                protocols,
+            )
+
             yield
 
             # --- SHUTDOWN: runs once when the server is stopping ---
@@ -210,7 +273,11 @@ async def _lifespan(_app: Starlette) -> AsyncGenerator[None, None]:  # noqa: RUF
             routes=all_routes,
             lifespan=_lifespan,
             middleware=[
-                Middleware(_PlatformHeaderMiddleware, get_server_version=self._build_server_version),
+                Middleware(InboundRequestLoggingMiddleware),  # type: ignore[arg-type]
+                Middleware(  # type: ignore[arg-type]
+                    _PlatformHeaderMiddleware,
+                    get_server_version=self._build_server_version,
+                ),
             ],
             **kwargs,
         )
 
@@ -15,6 +15,7 @@
 """
 import os
 from typing import Optional
+
 from typing_extensions import Self
 
 # ======================================================================
 
@@ -0,0 +1,135 @@
+# ---------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# ---------------------------------------------------------
+"""Inbound request logging middleware for Azure AI Agent Server hosts.
+
+A pure-ASGI middleware that logs every inbound HTTP request at INFO level
+(start) and at INFO or WARNING level (completion, depending on status code).
+
+Behaviour:
+- Logs method + path (no query string) on start.
+- Logs method + path + status code + duration on completion.
+- Correlation headers (``x-request-id``, ``x-ms-client-request-id``) are
+  included when present.
+- OTel trace ID is included when an active trace exists.
+- Status >= 400 → WARNING; otherwise → INFO.
+- Unhandled exceptions → forced status 500, WARNING.
+"""
+
+from __future__ import annotations
+
+import logging
+import time
+from typing import Any, MutableMapping
+
+from starlette.types import ASGIApp, Receive, Scope, Send
+
+logger = logging.getLogger("azure.ai.agentserver")
+
+
+def _extract_header(headers: list[tuple[bytes, bytes]], name: bytes) -> str | None:
+    """Extract a header value from raw ASGI headers.
+
+    :param headers: Raw ASGI header tuples.
+    :type headers: list[tuple[bytes, bytes]]
+    :param name: Lower-case header name to look up.
+    :type name: bytes
+    :return: Decoded header value, or ``None`` if not found.
+    :rtype: str | None
+    """
+    for key, value in headers:
+        if key == name:
+            return value.decode("latin-1")
+    return None
+
+
+def _get_trace_id() -> str | None:
+    """Return the current OTel trace ID hex string, or ``None``.
+
+    :return: Hex-encoded trace ID from the current OTel span, or ``None``.
+    :rtype: str | None
+    """
+    try:
+        from opentelemetry import trace as _trace  # pylint: disable=import-outside-toplevel
+
+        span = _trace.get_current_span()
+        ctx = span.get_span_context()
+        if ctx and ctx.trace_id:
+            return format(ctx.trace_id, "032x")
+    except Exception:  # pylint: disable=broad-exception-caught
+        pass
+    return None
+
+
+class InboundRequestLoggingMiddleware:
+    """Pure-ASGI middleware that logs inbound HTTP requests.
+
+    Unlike ``BaseHTTPMiddleware``, this passes the ``receive`` callable
+    through to the inner application untouched, preserving
+    ``request.is_disconnected()`` behaviour.
+
+    Wired automatically by :class:`AgentServerHost` so that all protocol
+    hosts (responses, invocations, etc.) get consistent inbound logging.
+
+    :param app: The inner ASGI application.
+    :type app: ASGIApp
+    """
+
+    def __init__(self, app: ASGIApp) -> None:
+        self.app = app
+
+    async def __call__(self, scope: Scope, receive: Receive, send: Send) -> None:
+        if scope["type"] != "http":
+            await self.app(scope, receive, send)
+            return
+
+        method: str = scope.get("method", "?")
+        path: str = scope.get("path", "/")
+        raw_headers: list[tuple[bytes, bytes]] = scope.get("headers", [])
+
+        request_id = _extract_header(raw_headers, b"x-request-id")
+        client_request_id = _extract_header(raw_headers, b"x-ms-client-request-id")
+        trace_id = _get_trace_id()
+
+        extra_parts: list[str] = []
+        if request_id:
+            extra_parts.append(f"x-request-id={request_id}")
+        if client_request_id:
+            extra_parts.append(f"x-ms-client-request-id={client_request_id}")
+        if trace_id:
+            extra_parts.append(f"trace_id={trace_id}")
+        extra_str = f" [{', '.join(extra_parts)}]" if extra_parts else ""
+
+        logger.info("Inbound %s %s started%s", method, path, extra_str)
+
+        status_code: int | None = None
+        start = time.monotonic()
+
+        async def _send_wrapper(message: MutableMapping[str, Any]) -> None:
+            nonlocal status_code
+            if message["type"] == "http.response.start":
+                status_code = message.get("status", 0)
+            await send(message)
+
+        try:
+            await self.app(scope, receive, _send_wrapper)
+        except Exception:
+            elapsed_ms = (time.monotonic() - start) * 1000
+            logger.warning(
+                "Inbound %s %s failed with status 500 in %.1fms%s",
+                method, path, elapsed_ms, extra_str,
+            )
+            raise
+
+        elapsed_ms = (time.monotonic() - start) * 1000
+
+        if status_code is not None and status_code >= 400:
+            logger.warning(
+                "Inbound %s %s completed with status %d in %.1fms%s",
+                method, path, status_code, elapsed_ms, extra_str,
+            )
+        else:
+            logger.info(
+                "Inbound %s %s completed with status %s in %.1fms%s",
+                method, path, status_code, elapsed_ms, extra_str,
+            )
@@ -245,7 +245,7 @@ def request_span(
     if x_request_id:
         ctx = _otel_baggage.set_baggage("x_request_id", x_request_id, context=ctx)
 
-    with tracer.start_as_current_span(
+    with tracer.start_as_current_span(  # type: ignore[reportGeneralTypeIssues]
         name=name,
         attributes=attrs,
         kind=trace.SpanKind.SERVER,
@@ -549,6 +549,7 @@ def _setup_trace_export(provider: Any, connection_string: str) -> None:
         return
     try:
         from opentelemetry.sdk.trace.export import BatchSpanProcessor
+
         from azure.monitor.opentelemetry.exporter import AzureMonitorTraceExporter  # type: ignore[import-untyped]
     except ImportError:
         logger.warning("Trace export requires azure-monitor-opentelemetry-exporter.")
@@ -567,6 +568,7 @@ def _setup_log_export(resource: Any, connection_string: str) -> None:
         from opentelemetry._logs import set_logger_provider
         from opentelemetry.sdk._logs import LoggerProvider, LoggingHandler
         from opentelemetry.sdk._logs.export import BatchLogRecordProcessor
+
         from azure.monitor.opentelemetry.exporter import AzureMonitorLogExporter  # type: ignore[import-untyped]
     except ImportError:
         logger.warning("Log export requires azure-monitor-opentelemetry-exporter.")
@@ -615,9 +617,12 @@ def _setup_otlp_log_export(resource: Any, endpoint: str) -> None:
         from opentelemetry._logs import set_logger_provider
         log_provider = LoggerProvider(resource=resource)
         set_logger_provider(log_provider)
-    log_provider.add_log_record_processor(BatchLogRecordProcessor(
-        OTLPLogExporter(endpoint=endpoint)))  # type: ignore[union-attr]
-    log_provider.add_log_record_processor(_BaggageLogRecordProcessor())  # type: ignore[arg-type]
+    log_provider.add_log_record_processor(  # type: ignore[union-attr]
+        BatchLogRecordProcessor(OTLPLogExporter(endpoint=endpoint))
+    )
+    log_provider.add_log_record_processor(  # type: ignore[union-attr]
+        _BaggageLogRecordProcessor()  # type: ignore[arg-type]
+    )
     # Note: LoggingHandler is NOT added here to avoid duplicating the
     # handler already installed by _setup_log_export. The OTel LoggerProvider
     # receives log records via the handler added there (or from direct OTel
 
@@ -2,4 +2,4 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # ---------------------------------------------------------
 
-VERSION = "2.0.0b1"
+VERSION = "2.0.0b2"