aws-appsync - Appsync - 如何从管道解析器中的多个函数返回响应

Question

input CarInput{ 
    name: String
    brand: String
}

type Car{   
    id: ID  
    name: String    
    brand: String
}

type Vehicle{   
    id: ID  
    carId: Id
}    

type CustomResponse{
    createdCar : Car
    allCars: [Car]
}

type Mutation {
    createCar(input: CarInput): CustomResponse
}

createCar 的附加管道解析器

映射模板之前

{}

1 - CreateCarFunction

请求映射模板

{
  "version" : "2017-02-28",
  "operation": "Invoke",
  "payload":{ 
  "body":$util.toJson($context.args.input),
  "resource":"/car",
  "httpmethod":"POST"
  }
}

响应映射模板

$context.result.body

2 - CreateVehicleFunction

请求映射模板

{
  "version" : "2017-02-28",
  "operation": "Invoke",
  "payload":{ 
  "body":$util.toJson($ctx.prev.result.id),
  "resource":"/vehicle",
  "httpmethod":"POST"
  }
}

响应映射模板

$context.result.body

3 - GetCarsFunction

请求映射模板

{
  "version" : "2017-02-28",
  "operation": "Invoke",
  "payload": {  
  "body":"",
  "resource":"/getCars" ,
  "httpmethod":"GET"
  }
}

响应映射模板

$context.result.body

映射模板后

 $util.toJson($ctx.result)

数据源是 Lamda。我将从 CreateCarFunction、CreateVehicleFunction 和 GetCarsFunction 得到三种不同的响应。

mutation{createCar(input:
{
 name: "A6"
 brand: "Audi"
})
 {
   createdCar  
   {
     id
     name
     brand
   }

   allCars
   {
     id
     name
     brand
   }   
 }

我想要这样的回应

{
  "data": {
    "createCar": {
      "createdCar  ": {
                        id : "2"
                        name : "A6"
                        brand : "Audi"
                      },
      "allCars":  [
                     {
                        id : "1"
                        name : "S"
                        brand : "Benz"
                     },
                     {
                        id : "2"
                        name : "A6"
                        brand : "Audi"
                     }
                 ]

          }
}

所以我需要 CreateCarFunction 和 GetCarsFunction 的响应，以便将 CustomResponse 类型填充为输出。我如何实现这一目标？

Answer 1

感谢您提供该问题的所有相关详细信息。您可以通过将输出(在响应映射模板中)添加到 $ctx.stash 来将数据从一个函数传递到下一个函数。 $ctx.stash 是一个可变对象，它在管道解析器的整个生命周期中保持不变。

将每个函数的响应映射模板修改为类似

创建汽车函数

$util.qr($ctx.stash.put("createdCar", $ctx.result.body))
$context.result.body

获取汽车函数

$util.qr($ctx.stash.put("allCars", $ctx.result.body))
$context.result.body

(第一行将结果添加到存储中。第二行像以前一样返回请求的主体。)

然后在您的 After 映射模板中，您可以反序列化结果

$util.toJson($ctx.stash)