Распечатать все REST-запросы / ответы в журналах AWS Cloud watch - PullRequest
Новая
       88

Распечатать все REST-запросы / ответы в журналах AWS Cloud watch

0 голосов
/ 01 ноября 2019

Я использую лямбда-функцию AWS. Я сделал несколько вызовов API REST в этой лямбда-функции. Я хочу видеть журналы для всех запросов / ответов в журналах AWS cloudwatch. Я использую log4j для печати журналов в cloudwatch. Один из способов сделать это - добавить журнал самостоятельно для каждого запроса / ответа. Я не хочу этого делать. Есть ли какой-нибудь способ в log4j, где я могу добавить некоторую конфигурацию в log4j.xml, и он начинает печатать все запросы / ответы http-вызовов.

Я делаю вызов API следующим образом: 

public SEDPSHttpResponse post(SEDPSHttpRequest request) throws InterruptedIOException {

        URIBuilder builder;
        SEDPSHttpResponse sedpsHttpResponse = new SEDPSHttpResponse();
        try {
            builder = new URIBuilder(request.getUrl());
            log.info("api url -  {} ",request.getUrl());
            if (request.getParams() != null && !request.getParams().isEmpty())
                builder.addParameters(request.getParams());

            HttpPost post = new HttpPost(builder.build());

            if (request.getHeaders() != null) {
                for (Map.Entry<String, String> entry : request.getHeaders().entrySet()) {
                    post.setHeader(entry.getKey(), entry.getValue());
                }
            }

            StringEntity entity;

            entity = new StringEntity(request.getBody());
            post.setEntity(entity);

            CloseableHttpClient httpClient = HttpClients.createDefault();
            CloseableHttpResponse response = httpClient.execute(post);
            sedpsHttpResponse.setBody(EntityUtils.toString(response.getEntity()));
            sedpsHttpResponse.setHeaders(convertHeadersToMap(response.getAllHeaders()));
            sedpsHttpResponse.setHttpCode(response.getStatusLine().getStatusCode());
            log.info("response returned from api - {} ",sedpsHttpResponse);
            return sedpsHttpResponse;
        } catch (SocketTimeoutException | ConnectTimeoutException e) {
            log.error("Api timeout occurred - {} " + e.getMessage());
            throw new InterruptedIOException("Retrying exception");
        } catch (URISyntaxException | UnsupportedEncodingException e) {
            log.error("Bad request exception - {} " + e.getMessage());
            sedpsHttpResponse.setHttpCode(HttpStatus.SC_BAD_REQUEST);
            sedpsHttpResponse.setBody(e.getMessage());
            return sedpsHttpResponse;
        } catch (IOException e) {
            log.error("Exception occurred while calling api - {} " + e.getMessage());
            sedpsHttpResponse.setHttpCode(HttpStatus.SC_INTERNAL_SERVER_ERROR);
            sedpsHttpResponse.setBody(e.getMessage());
            return sedpsHttpResponse;
        }

    }

Ниже приведен мой log4j.xml 

<Configuration status="INFO" packages="com.amazonaws.services.lambda.runtime.log4j2">
    <Appenders>
        <Console name="CONSOLE" target="SYSTEM_OUT">
            <PatternLayout pattern="%d{dd MMM yyyy HH:mm:ss,SSS} [%p] %X{RequestId} ~(%t) %c: %m%n"/>
        </Console>
    </Appenders>
    <Loggers>
        <Root level="INFO">
            <AppenderRef ref="CONSOLE"/>
        </Root>
    </Loggers>

 </Configuration>

Мне удалось зарегистрировать запрос http в журналах cloudwatch. добавив следующие 2 строки в log4j.xml, но не в состоянии записать ответ. Мне нужно добавить ответ вручную, используя log.info (ответ) 

  <logger name="org.apache.http.wire" level="debug" />
     <logger name="org.apache.http.client" level="debug" />

Если у кого-то есть какой-то умный способ добавления ответа, напримерэто случилось с просьбой. Пожалуйста, предложите.

...