Method async_request

agentops/client/http/http_client.py:112–169

Make an async HTTP request and return JSON response Args: method: HTTP method (e.g., 'get', 'post', 'put', 'delete') url: Full URL for the request data: Request payload (for POST, PUT methods) headers: Request headers time

(
        cls,
        method: str,
        url: str,
        data: Optional[Dict] = None,
        headers: Optional[Dict] = None,
        timeout: int = 30,
    )

    @classmethod
    async def async_request(
        cls,
        method: str,
        url: str,
        data: Optional[Dict] = None,
        headers: Optional[Dict] = None,
        timeout: int = 30,
    ) -> Optional[Dict]:
        """
        Make an async HTTP request and return JSON response

        Args:
            method: HTTP method (e.g., 'get', 'post', 'put', 'delete')
            url: Full URL for the request
            data: Request payload (for POST, PUT methods)
            headers: Request headers
            timeout: Request timeout in seconds

        Returns:
            JSON response as dictionary, or None if request failed
        """
        if not AIOHTTP_AVAILABLE:
            logger.warning("aiohttp not available, cannot make async request")
            return None

        try:
            session = await cls.get_async_session()
            if not session:
                return None

            logger.debug(f"Making async {method} request to {url}")

            # Prepare request parameters
            kwargs = {"timeout": aiohttp.ClientTimeout(total=timeout), "headers": headers or {}}

            if data and method.lower() in ["post", "put", "patch"]:
                kwargs["json"] = data

            # Make the request
            async with session.request(method.upper(), url, **kwargs) as response:
                logger.debug(f"Async request response status: {response.status}")

                # Check if response is successful
                if response.status >= 400:
                    return None

                # Parse JSON response
                try:
                    response_data = await response.json()
                    logger.debug(
                        f"Async request successful, response keys: {list(response_data.keys()) if response_data else 'None'}"
                    )
                    return response_data
                except Exception:
                    return None

        except Exception:
            return None