subqueries

サブクエリは、別のクエリへの入力として使用できるネストされた 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