DescribeLogStreamsResult result = client.describeLogStreams(describeRequest);
List logStreams = result.getLogStreams();
for(LogStream stream : logStreams) {
GetLogEventsRequest eventsRequest = new GetLogEventsRequest();
eventsRequest.setLogGroupName(groupName);
eventsRequest.setLogStreamName(stream.getLogStreamName());
eventsRequest.setStartFromHead(true);
eventsRequest.setStartTimestamp(startTime);
eventsRequest.setEndTimestamp(endTime);
GetLogEventsResult eventsResult = client.getLogEvents(eventsRequest);
List events = eventsResult.getEvents();
Collections.reverse(events);
for(OutputLogEvent event : events) {
// process log event
}
}
在此例中,我们使用 Amazon CloudWatch Logs 的 client.describeLogStreams(describeRequest)
方法获取 LogStream
列表。然后使用 GetLogEventsRequest
实例来获取每个流的日志并使用 Collections.reverse(events)
来按降序对日志进行排序。
上一篇:AWSCloudwatchLogsInsights使用哪种查询语言?
下一篇:AwscloudwatchlogssendtostandaloneELK 将AWSCloudWatch日志发送到独立的ELK