如何在 AWS appSync 中的 Apache Velocity 请求映射模板中操作字符串和数组

Question

这是我第一次使用 VTL，所以如果其中有非常愚蠢的东西，请更正我的代码。

我想要实现的目标

{
"cities": ["jaipur", "mumbai", "delhi", "sheros", "jalandhar", "bengaluru"]
}

Graphql schema：

type Query{
getCitiesForGroups: String
}

默认响应模板：

#if($ctx.error)
$utils.error($ctx.error.message, $ctx.error.type)
#end
$utils.toJson($utils.rds.toJsonObject($ctx.result)[0])

使用默认响应模板，我得到的结果

{ "data": { "getCitiesForGroups": [ "{groupcity=jaipur}", "{groupcity=mumbai}", "{groupcity=delhi}", "{groupcity=sheros}", "{groupcity=jalandhar}", "{groupcity=bengaluru}" ] } }

我的请求模板

{
"version": "2018-05-29",
"statements": [
"select DISTINCT LOWER(city) as city from public.Groups"
]
}

为了获得所需的输出，我更改了响应模板，因为我想遍历从数据库获得的响应，并使用 AWS 解析器映射文档中给出的子字符串方法从字符串中删除{city=}，这就是我面临问题的地方。

我的响应模板

#if($ctx.error)
$utils.error($ctx.error.message, $ctx.error.type)
#end
#set ($rawListOfCities = $utils.rds.toJsonObject($ctx.result)[0])
#set ($sanitisedListOfCities = [])
#foreach( $city in $rawListOfCities )
#set ($equalToIndex = $city.indexOf("="))
#set ($equalToIndex = $equalToIndex + 1)
#set ($curlyLastIndex = $city.lastIndexOf("}"))
#set ($tempCity = $city.substring($equalToIndex, $curlyLastIndex))
## #set ($tempCity = $city)
$util.qr($sanitisedListOfCities.add($tempCity))
#end
$util.toJson($sanitisedListOfCities)

我得到的回复：

{
"data": {
"getCitiesForGroups": "[null, null, null, null, null, null]"
}
}

但是，当我使用该行#set ($tempCity = $city)并注释掉其上方的行时，我得到以下响应：

{
"data": {
"getCitiesForGroups": "[{city=jaipur}, {city=mumbai}, {city=delhi}, {city=sheros}, {city=jalandhar}, {city=bengaluru}]"
}
}

这意味着$city具有值{city=jaipur}，因此我想对其进行清理并将其添加到($sanitisedListOfCities)并将其作为响应返回。

但是我得到null作为结果子字符串方法。

那么，如何清理来自数据库的响应并返回它呢？

Answer 1

我遇到了类似的问题，这就是我解决它的方式。

首先，你的 Graphql 模式应该看起来像这样，

type Query {
getCitiesForGroups: cityList
}
type cityList {
cities: [String]
}

您的请求映射模板，

{
"version": "2018-05-29",
"statements": [
"select DISTINCT LOWER(city) as city from public.Groups"
]
}

最后是您的响应映射模板

#set($cityList = [])
#set($resMap = {})
#if($ctx.error)
$utils.error($ctx.error.message, $ctx.error.type)
#end
#foreach($item in $utils.rds.toJsonObject($ctx.result)[0])
$util.qr($cityList.add($item.city))
#end
$util.qr($resMap.put("cities", $cityList))
#return($resMap)

预期响应(完成(

{
"data": {
"getCitiesForGroups": {
"cities": [
"jaipur",
"mumbai",
"delhi",
"sheros",
"jalandhar",
"bengaluru"
]
}
}
}

我希望这对你有所帮助。