in sample-apps/java-events/src/main/java/example/HandlerCWLogs.java [27:49]
public String handleRequest(CloudWatchLogsEvent event, Context context)
{
LambdaLogger logger = context.getLogger();
String response = new String("200 OK");
Decoder decoder = Base64.getDecoder();
byte[] decodedEvent = decoder.decode(event.getAwsLogs().getData());
StringBuilder output = new StringBuilder();
try {
GZIPInputStream inputStream = new GZIPInputStream(new ByteArrayInputStream(decodedEvent));
InputStreamReader inputStreamReader = new InputStreamReader(inputStream, StandardCharsets.UTF_8);
BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
bufferedReader.lines().forEach( line -> {
logger.log(line);
output.append(line);
});
logger.log(output.toString());
} catch(IOException e) {
logger.log("ERROR: " + e.toString());
}
// log execution details
Util.logEnvironment(event, context, gson);
return response;
}