AWS AppSyncのPipeline Resolverで複数データリソースを扱う場合のVTLの書き方

# 従業員IDを指定してDynamoDBから1件情報を取得します。
{
    "version": "2017-02-28",
    "operation": "GetItem",
    "key": {
        "id": $util.dynamodb.toDynamoDBJson($ctx.args.id),
    },
}

# 従業員情報をレスポンスに設定します。
$util.toJson($context.result)

# 前ファンクションの結果（従業員情報）に紐づく部署情報を取得します。
{
    "operation": "GetItem",
    "key": {
        # 前ファンクションの結果は $ctx.prev.resultで参照できます。
        # 部署IDを指定してDynamoDBから1件情報を取得します。
        "id": $util.dynamodb.toDynamoDBJson($ctx.prev.result.departmentId),
    }
}

#if($ctx.error)
        $util.error($ctx.error.message, $ctx.error.type)
#end

# 前ファンクションの結果（従業員情報）と今回の結果（部署情報）をマージします。
# オブジェクトに新しくプロパティを追加する場合は putメソッドを使います。
# putメソッドを使う場合は $util.qr で囲む必要があります。
$util.qr($ctx.prev.result.put("departmentName", $ctx.result.name))

# マージ結果をレスポンスに設定します。
$util.toJson($ctx.prev.result)

{
    "operation" : "Scan",
    # 複数件検索ではfilterで検索条件を指定します。
    "filter" : {
        # 具体的な検索条件はexpressionで定義します。
        # 今回は契約者名が一致することが条件です。
        "expression": "contractor = :contractor",
        # 検索条件で使う変数はあらかじめexpressionValuesで初期化します。
        "expressionValues" : {
            ":contractor" : $util.dynamodb.toDynamoDBJson($ctx.args.contractor)
        }
    }
}

# 契約情報をレスポンスに設定します。
$util.toJson($context.result)

# 前ファンクションで取得した契約情報から商品IDを抽出します。
#set($productIds = [])
#set($contracts = $ctx.prev.result.items)
#foreach($c in $contracts)
    #foreach( $id in $c.productIds )
        #if(!$productIds.contains($id))
            $util.qr($productIds.add($id))
        #end
    #end
#end

{
    "version" : "2017-02-28",
    "operation" : "Scan",
    "filter" : {
        # 「複数の値のどれかに一致する」という条件はcontains関数で実現します。
        "expression": "contains(:ids, id)",
        "expressionValues" : {
            ":ids" : $util.dynamodb.toDynamoDBJson($productIds)
        }
    }
}

#if($ctx.error)
        $util.error($ctx.error.message, $ctx.error.type)
#end

# 前ファンクションの結果（契約情報）と今回の結果（商品情報）をマージします。
#foreach($c in $ctx.prev.result.items)
    #set($products = [])    
    # 商品情報をイテレート
    #foreach( $p in $ctx.result.items )
        # 契約情報に含まれる商品が見つかったら
        #if($c.productIds.contains($p.id))
            # $productsにaddします。
            $util.qr($products.add($p))
        #end
    #end
        
    # 商品情報を契約情報に追加します。
    #set($temp = { "items": $products })
    $util.qr($contract.put("products", $temp))
#end

# マージした情報をレスポンスに設定します。
$util.toJson($ctx.prev.result)