时间戳

首页 > 解决方案 > Appsync - 如何从管道解析器中的多个函数返回响应

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

问题描述

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 - 创建汽车功能

请求映射模板

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

响应映射模板

$context.result.body

2 - 创建车辆功能

请求映射模板

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

响应映射模板

$context.result.body

3 - 获取汽车功能

请求映射模板

{
  "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类型填充为输出。我如何实现这一目标？

标签： aws-appsync

解决方案

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

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

创建汽车函数

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

GetCarsFunction

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

（第一行将结果添加到存储中。第二行像以前一样返回请求的正文。）

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

$util.toJson($ctx.stash)

推荐阅读