하위 쿼리

하위 쿼리는 다른 쿼리에 대한 입력으로 사용할 수 있는 중첩된 Logs Insights 쿼리입니다. 하위 쿼리를 사용하여 중간 결과 세트를 도출한 다음 후속 명령에서 사용할 수 있습니다.

구문

필터의 하위 쿼리


filter <field> in (
    <subquery>
)

파라미터

<subquery> - 결과 집합을 반환하는 유효한 Logs Insights 쿼리입니다. 하위 쿼리는 외부 쿼리에서 참조하는 필드를 생성해야 합니다.

예제

예예제 1: 다운스트림 서비스에서 오류가 발생한 요청 찾기

이 예제에서는 하위 쿼리를 사용하여 기본 서비스에서 다운스트림 서비스에서 오류가 발생한 요청을 식별하는 방법을 보여줍니다. 이는 분산 시스템의 계단식 장애 문제를 해결하는 데 유용합니다.


filter requestId in (
    SOURCE '/aws/lambda/database-service'
    | filter errorType = "DatabaseConnectionTimeout"
    | fields requestId
)
| fields @timestamp, requestId, endpoint, userId, responseTime
| sort @timestamp desc

이 쿼리는 다음과 같습니다.

하위 쿼리는 데이터베이스 서비스에서 연결 제한 시간이 발생한 모든 requestId 값을 찾습니다.
외부 쿼리는 기본 서비스의 로그를 필터링하여 오류가 발생하기 쉬운 요청 IDs
결과에는 영향을 받은 엔드포인트 및 사용자를 포함하여 다운스트림에서 실패한 요청의 전체 컨텍스트가 표시됩니다.

이 패턴은 다운스트림 장애의 업스트림 영향을 이해하는 데 도움이 됩니다.

예예제 2: 대상 조사에 대한 자주 실패하는 요청 식별

이 예제에서는 집계와 함께 하위 쿼리를 사용하여 반복적으로 실패하는 요청을 찾는 방법을 보여줍니다. 이는 일시적인 오류가 아닌 체계적인 문제를 나타내는 경우가 많습니다.


filter requestId in (
    SOURCE '/aws/lambda/payment-processor'
    | filter status = "FAILED"
    | stats count(*) as failureCount by requestId
    | filter failureCount > 3
    | fields requestId
)
| fields @timestamp, requestId, customerId, amount, failureReason
| sort @timestamp asc