기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

CloudTrail 프로세싱 라이브러리 사용

CloudTrail 처리 라이브러리는 AWS CloudTrail 로그를 처리하는 쉬운 방법을 제공하는 Java 라이브러리입니다. CloudTrail SQS 대기열에 대한 구성 세부 정보를 제공하고 이벤트를 처리하는 코드를 작성합니다. CloudTrail 프로세싱 라이브러리가 나머지 작업을 수행합니다. Amazon SQS 대기열을 폴링하고, 대기열 메시지를 읽고 파싱하며, 로그 파일을 CloudTrail 다운로드하고, 로그 파일의 이벤트를 파싱하고, 이벤트를 Java 객체로 코드에 전달합니다.

CloudTrail 프로세싱 라이브러리는 확장성이 뛰어나고 내결함성이 뛰어납니다. 로그 파일을 병렬 처리하여 로그를 필요한 만큼 처리할 수 있습니다. 또한 네트워크 시간 초과 및 액세스할 수 없는 리소스와 관련된 네트워크 장애를 처리합니다.

다음 항목에서는 CloudTrail 처리 라이브러리를 사용하여 Java 프로젝트의 CloudTrail 로그를 처리하는 방법을 보여줍니다.

라이브러리는 Apache 라이선스 오픈 소스 프로젝트로 제공되며 다음에서 사용할 수 있습니다. GitHub https://github.com/aws/aws-cloudtrail-processing-library 라이브러리 소스에는 자체 프로젝트를 생성할 때 토대로 사용할 수 있는 샘플 코드가 포함되어 있습니다.

최소 요구 사항

CloudTrail 처리 라이브러리를 사용하려면 다음이 있어야 합니다.

처리 로그 CloudTrail

Java 애플리케이션에서 CloudTrail 로그를 처리하려면:

프로젝트에 CloudTrail 프로세싱 라이브러리 추가

CloudTrail 프로세싱 라이브러리를 사용하려면 자바 프로젝트의 클래스 경로에 프로세싱 라이브러리를 추가하세요.

Apache Ant 프로젝트에 라이브러리 추가

Apache Maven 프로젝트에 라이브러리 추가

CloudTrail 프로세싱 라이브러리는 Apache Maven에서 사용할 수 있습니다. 프로젝트의 pom.xml 파일에 단일 종속성을 작성하여 프로젝트에 라이브러리를 추가할 수 있습니다.

Eclipse 프로젝트에 라이브러리 추가

IntelliJ 프로젝트에 라이브러리 추가

CloudTrail 프로세싱 라이브러리 구성

런타임에 로드되는 클래스 경로 속성 파일을 만들거나 ClientConfiguration 객체를 만들고 옵션을 수동으로 설정하여 CloudTrail 처리 라이브러리를 구성할 수 있습니다.

속성 파일 제공

애플리케이션에 구성 옵션을 제공하는 classpath 속성 파일을 작성할 수 있습니다. 다음 예제 파일에서는 설정할 수 있는 옵션을 보여 줍니다.

# AWS access key. (Required)
accessKey = your_access_key

# AWS secret key. (Required)
secretKey = your_secret_key

# The SQS URL used to pull CloudTrail notification from. (Required)
sqsUrl = your_sqs_queue_url

# The SQS end point specific to a region.
sqsRegion = us-east-1

# A period of time during which Amazon SQS prevents other consuming components
# from receiving and processing that message.
visibilityTimeout = 60

# The S3 region to use.
s3Region = us-east-1

# Number of threads used to download S3 files in parallel. Callbacks can be
# invoked from any thread.
threadCount = 1

# The time allowed, in seconds, for threads to shut down after
# AWSCloudTrailEventProcessingExecutor.stop() is called. If they are still
# running beyond this time, they will be forcibly terminated.
threadTerminationDelaySeconds = 60

# The maximum number of AWSCloudTrailClientEvents sent to a single invocation
# of processEvents().
maxEventsPerEmit = 10

# Whether to include raw event information in CloudTrailDeliveryInfo.
enableRawEventInfo = false

# Whether to delete SQS message when the CloudTrail Processing Library is unable to process the notification.
deleteMessageUponFailure = false

다음 파라미터는 필수 파라미터입니다.

accessKey및 매개변수는 라이브러리에 자격 증명을 제공하므로 라이브러리가 사용자를 대신하여 액세스할 수 있습니다. secretKey AWS AWS

다른 파라미터의 기본값은 라이브러리에서 설정됩니다. 자세한 내용은 AWS CloudTrail Processing Library 참조 단원을 참조하세요.

생성: ClientConfiguration

classpath 속성에서 옵션을 설정하는 대신, 다음 예와 같이 ClientConfiguration 객체에서 옵션을 초기화하고 설정하여 AWSCloudTrailProcessingExecutor에 옵션을 제공할 수 있습니다.

ClientConfiguration basicConfig = new ClientConfiguration(
    "http://sqs.us-east-1.amazonaws.com/123456789012/queue2",
    new DefaultAWSCredentialsProviderChain());

basicConfig.setEnableRawEventInfo(true);
basicConfig.setThreadCount(4);
basicConfig.setnEventsPerEmit(20);

이벤트 프로세서 구현

CloudTrail 로그를 처리하려면 CloudTrail 로그 데이터를 수신하는 EventsProcessor an을 구현해야 합니다. 다음은 구현의 예입니다.

public class SampleEventsProcessor implements EventsProcessor {

    public void process(List<CloudTrailEvent> events) {
        int i = 0;
        for (CloudTrailEvent event : events) {
            System.out.println(String.format("Process event %d : %s", i++, event.getEventData()));
        }
    }
}

를 구현할 EventsProcessor 때는 CloudTrail 이벤트를 보내는 데 AWSCloudTrailProcessingExecutor 사용하는 process() 콜백을 구현합니다. 이벤트는 CloudTrailClientEvent 객체 목록에 제공됩니다.

CloudTrailClientEvent객체는 CloudTrail 이벤트 CloudTrailEvent 및 배달 정보를 읽는 데 사용할 수 CloudTrailEventMetadata 있는 광고를 제공합니다.

이 간단한 예에서는 SampleEventsProcessor에 전달된 각 이벤트에 대한 이벤트 정보를 인쇄합니다. 자체 구현에서는 적절한 방식으로 로그를 처리할 수 있습니다. AWSCloudTrailProcessingExecutor에 전송할 이벤트가 있고 실행되는 동안에는 계속해서 EventsProcessor로 이벤트를 전송합니다.

Processing Executor 인스턴스화 및 실행

속성 파일이나 ClientConfiguration 클래스를 사용하여 CloudTrail 처리 라이브러리의 구성 값을 EventsProcessor 작성하고 설정한 후 이러한 요소를 사용하여 를 초기화하고 사용할 수 있습니다. AWSCloudTrailProcessingExecutor

public class SampleApp {
  public static void main(String[] args) throws InterruptedException {
    AWSCloudTrailProcessingExecutor executor = new
      AWSCloudTrailProcessingExecutor.Builder(new SampleEventsProcessor(),
        "/myproject/cloudtrailprocessing.properties").build();

    executor.start();
    Thread.sleep(24 * 60 * 60 * 1000); // let it run for a while (optional)
    executor.stop(); // optional
  }
}

고급 주제

처리할 이벤트 필터링

기본적으로 Amazon SQS 대기열의 S3 버킷에 있는 모든 로그 및 로그에 포함된 모든 이벤트는 ​EventsProcessor에 전송됩니다. CloudTrail 처리 라이브러리는 CloudTrail 로그를 가져오는 데 사용되는 소스를 필터링하고 처리하려는 이벤트를 필터링하기 위해 구현할 수 있는 선택적 인터페이스를 제공합니다.

데이터 이벤트 처리

데이터 이벤트를 CloudTrail 처리할 때 정수 (int) 이든 a float (10진수가 포함된 숫자) 이든 상관없이 숫자를 원래 형식으로 보존합니다. 데이터 이벤트 필드에 정수가 있는 이벤트의 경우 CloudTrail 이전에는 이러한 숫자를 부동 소수점으로 처리했습니다. 현재 에서는 이러한 필드의 숫자를 원래 형식을 유지하여 CloudTrail 처리합니다.

자동화가 중단되지 않도록 하려면 CloudTrail 데이터 이벤트를 처리하거나 필터링하는 데 사용하는 코드나 자동화를 유연하게 int 사용하고 float 형식이 지정된 숫자를 모두 허용하도록 하는 것이 좋습니다. 최상의 결과를 얻으려면 처리 라이브러리 버전 1.4.0 이상을 사용하십시오. CloudTrail

다음 코드 조각 예에서는 데이터 이벤트의 ResponseParameters 블록에 있는 desiredCount 파라미터의 float 형식 숫자인 2.0을 보여 줍니다.

"eventName": "CreateService",
    "awsRegion": "us-east-1",
    "sourceIPAddress": "000.00.00.00",
    "userAgent": "console.amazonaws.com",
    "requestParameters": {
        "clientToken": "EXAMPLE",
        "cluster": "default",
        "desiredCount": 2.0
...

다음 코드 조각 예에서는 데이터 이벤트의 ResponseParameters 블록에 있는 desiredCount 파라미터의 int 형식 숫자인 2를 보여 줍니다.

"eventName": "CreateService",
    "awsRegion": "us-east-1",
    "sourceIPAddress": "000.00.00.00",
    "userAgent": "console.amazonaws.com",
    "requestParameters": {
        "clientToken": "EXAMPLE",
        "cluster": "default",
        "desiredCount": 2
...

진행률 보고

ProgressReporter인터페이스를 구현하여 CloudTrail 프로세싱 라이브러리 진행 상황 보고를 사용자 정의하십시오. ProgressReporter다음 작업의 reportStart() 시작과 끝에서 호출되는 두 reportEnd() 메서드인 및 메서드를 선언합니다.

두 메서드는 수행된 작업에 대한 정보를 포함하는 ProgressStatus 객체를 수신합니다. progressState 멤버는 현재 작업을 식별하는 ProgressState 열거형의 멤버를 보유합니다. 이 멤버는 progressInfo 멤버에 추가 정보를 포함할 수 있습니다. 또한 reportStart()에서 반환할 수 있는 모든 객체는 reportEnd()에 전달되므로 이벤트 처리가 시작된 시간 등의 컨텍스트 정보를 제공할 수 있습니다.

다음은 작업이 완료될 때까지 걸리는 시간에 대한 정보를 제공하는 구현 예제입니다.

public class SampleProgressReporter implements ProgressReporter {
  private static final Log logger =
    LogFactory.getLog(DefaultProgressReporter.class);

  @Override
  public Object reportStart(ProgressStatus status) {
    return new Date();
  }

  @Override
  public void reportEnd(ProgressStatus status, Object startDate) {
    System.out.println(status.getProgressState().toString() + " is " +
      status.getProgressInfo().isSuccess() + " , and latency is " +
      Math.abs(((Date) startDate).getTime()-new Date().getTime()) + "
      milliseconds.");
  }
}

자체 ProgressReporter를 구현하지 않을 경우 실행 중인 상태의 이름을 인쇄하는 DefaultExceptionHandler가 대신 사용됩니다.

오류 처리

ExceptionHandler 인터페이스를 사용하면 로그 처리 중 예외가 발생할 경우 특수 처리를 제공할 수 있습니다. ExceptionHandler는 객체를 수신하는 단일 콜백 메서드 handleException()를 선언하고 이 콜백 메서드는 발생한 예외에 대한 컨텍스트가 포함된 ProcessingLibraryException 객체를 수신합니다.

전달된 ProcessingLibraryException의 getStatus() 메서드를 사용하여 예외 발생 시 실행된 작업을 확인하고 작업 상태에 대한 추가 정보를 구할 수 있습니다. ProcessingLibraryException은 Java의 표준 Exception 클래스에서 파생되므로 Exception 메서드 중 하나를 사용하여 예외에 대한 정보를 검색할 수도 있습니다.

다음 구현 예제를 참조하십시오.

public class SampleExceptionHandler implements ExceptionHandler{
  private static final Log logger =
    LogFactory.getLog(DefaultProgressReporter.class);

  @Override
  public void handleException(ProcessingLibraryException exception) {
    ProgressStatus status = exception.getStatus();
    ProgressState state = status.getProgressState();
    ProgressInfo info = status.getProgressInfo();

    System.err.println(String.format(
      "Exception. Progress State: %s. Progress Information: %s.", state, info));
  }
}

자체 ExceptionHandler를 제공하지 않을 경우 표준 오류 메시지를 인쇄하는 DefaultExceptionHandler가 대신 사용됩니다.

추가적인 리소스

CloudTrail 처리 라이브러리에 대한 자세한 내용은 다음을 참조하십시오.