4

我有一个 DynamoDB 表,其中包含客户端所需的所有数据,但是,我想调整客户端接收到的数据以减少客户端操作。

我的架构:

type StateCounty {
    id: ID!
    StateName: String
    CountyName: String
    FIPSST: Int
    FIPSCNTY: Int   
    Penetration: String
    Date: String

}

并返回一个自定义查询,我有以下类型:

type Query {
  getStateCountybyState(StateName: String): StateCountyConnection
}

这有效 - 并且通过一个简单的查询

query  getStateCountybyState {
     getStateCountybyState (StateName: "Delaware")   {
      items { 
       StateName
       CountyName
       Date    

    }
   }
  } 

结果按预期返回:

 {
      "StateName": "Delaware",
      "CountyName": "Kent",
      "Date": "02-01-2017"
    },
    {
      "StateName": "Delaware",
      "CountyName": "Sussex",
      "Date": "02-01-2016"
    },
    {
      "StateName": "Delaware",
      "CountyName": "New Castle",
      "Date": "02-01-2018"
  }

等等

我想以以下格式返回数据:

 {
   "StateName": "Delaware" {

     { "CountyName": "Kent",
      "Date": "02-01-2017"
      },
     {
      "CountyName": "Sussex",
      "Date": "02-01-2016"
     },
     {
      "CountyName": "New Castle",
      "Date": "02-01-2018"
     }
 }
}

我尝试将 GroupCounty: [StateCountyGroup] 添加到架构中:

type StateCounty {
    id: ID!
    StateName: String
    CountyName: String
    FIPSST: Int
    FIPSCNTY: Int   
    Penetration: String
    Date: String
    GroupCounty: [StateCountyGroup]
}

然后在查询中引用

query  getStateCountybyState {
     getStateCountybyState (StateName: "Delaware")   {
      items { 
       StateName
       CountyName
       Date  
       GroupCounty: [StateCountyGroup] 
    }
   }
  } 

我认为我的问题出在解析器中 - 目前,它被配置为使用 StateName 作为键,但我不确定如何将 StateName 从主查询传递到子查询。

解析器:

{
    "version" : "2017-02-28",
    "operation" : "Query",
    "query" : {
        "expression" : "StateName = :StateName",
        "expressionValues" : {
            ":StateName" : { "S" : "${context.arguments.StateName}" },
        }
    },
    "index" : "StateName-index-copy",
    "select" : "ALL_ATTRIBUTES",

}

任何指导表示赞赏 - 我已经多次阅读文档,但找不到示例。

更新

我尝试了 Richard 下面的建议——它绝对是在正确的轨道上,但是,尽管主题有多种变化,但我要么返回 null,要么返回以下错误(为简洁起见,我删除了错误中返回的一些县对象):

"message": "Unable to convert set($myresponse = {\n  \"Delaware\": 
[{SSA=8000, Eligibles=32295, FIPS=10001, StateName=Delaware, SSACNTY=0, 
Date=02-01-2016, CountyName=Kent, Enrolled=3066, Penetration=0.0949, 
FIPSCNTY=1, FIPSST=10, SSAST=8, id=6865}, 
{SSA=8010, Eligibles=91332, FIPS=10003, StateName=Delaware, SSACNTY=10, Date=02-01-2016, CountyName=New Castle, Enrolled=10322, Penetration=0.113, FIPSCNTY=3, FIPSST=10, SSAST=8, id=6866}, 
{SSA=0, Eligibles=10, FIPS=10, StateName=Delaware, SSACNTY=0, Date=02-01-2018, CountyName=Pending County Designation, Enrolled=0, Penetration=0, FIPSCNTY=0, FIPSST=10, SSAST=0, id=325}, 
{SSA=8000, Eligibles=33371, FIPS=10001, StateName=Delaware, SSACNTY=0, Date=02-01-2017, CountyName=Kent, Enrolled=3603, Penetration=0.108, FIPSCNTY=1, FIPSST=10, SSAST=8, id=3598}, 
{SSA=8020, Eligibles=58897, FIPS=10005, StateName=Delaware, SSACNTY=20, Date=02-01-2016, CountyName=Sussex, Enrolled=3760, Penetration=0.0638, FIPSCNTY=5, FIPSST=10, SSAST=8, id=6867})    \nnull\n\n to class java.lang.Object."
        }
      ]
    }
4

1 回答 1

2

通过阅读上述内容,听起来您的原始查询正在返回您想要的正确结果,但不是您希望的响应格式,因为您希望“StateName”成为顶级 JSON 键,其值为您作为参数传入的状态的 JSON 对象。那准确吗?如果是这样,那么为什么不使用已经有效但使用不同响应模板的相同查询。就像是:

#set($myresponse = {
  "$ctx.args.StateName": $ctx.result.items
})    
$util.toJson($myresponse)

请注意,$myresponse这与您在上面的示例不完全相同,因为"stateName" : "Delaware" { ... }JSON 不完全有效,所以我不想假设一个好的结构会是什么,但如果您已经得到,那么重点仍然存在您查询的正确结果我只是尝试更改您的 GraphQL 结果的结构。

现在,如果我误读了上述内容并且您没有从查询中获得正确的结果,那么我可以阅读您的“对子查询的主要查询”语句的另一种方式是您正在尝试将附加信息"filter"应用于您的查询结果. 如果是这种情况,那么你需要这样的东西:

{
    "version" : "2017-02-28",
    "operation" : "Query",
    "query" : {
        "expression" : "StateName = :StateName",
        "expressionValues" : {
            ":StateName" : { "S" : "${context.arguments.StateName}" },
        }
    },
    "index" : "StateName-index-copy",
    "select" : "ALL_ATTRIBUTES",
    "filter" : {
      "expression" : "#population >= :population",
      "expressionNames" : {
        "#population" : "population"
      },
      "expressionValues" : {
        ":population" : $util.dynamodb.toDynamoDBJson($ctx.args.population)
      }
    }
}

我在这里使用了一个示例,您的查询可能还需要按每个县的人口规模进行过滤。这可能不能代表您正在寻找的内容,但希望它有所帮助。

编辑更多信息 2018 年 4 月 16 日

我已经逐步编写了有关此的更多信息,以逐个了解这些概念。

这里的关键不仅仅是响应模板,还有您请求返回的字段(因为这是 GraphQL 的本质)。让我们通过示例来了解一下。现在您正在使用 GraphQL 返回单个项目(因为您的响应模板正在将数组转换为单个项目),因此您需要更改预期的 GraphQL 查询响应类型。假设您的架构中有一个 GraphQL 类型,如下所示:

type State {
    id: ID!
    population: String!
    governor: String!
}

type Query {
    allStates: [State]
}

如果您只是像上面那样转换模板中的响应,如果您运行以下内容,您将看到类似“类型不匹配错误,预期类型 LIST”的错误:

query {
  allStates{
    id
    population
  }
}

那是因为您的响应不再返回单个项目。相反,您需要更改 GraphQL 响应类型[State]以匹配您的模板转换正在执行的操作State,如下所示:

type State {
    StateName: String
}

type Query {
    allStates: State
}

现在,如果您的解析器请求模板正在执行返回项目列表的操作(如 DynamoDB 扫描或查询),您可以将列表转换为响应模板中的单个项目,如下所示:

#set($convert = {"StateName" : $ctx.result.items })
$util.toJson($convert)

然后运行以下 GraphQL 查询:

query {
  allStates{
    StateName
  }
}

您将得到一个包含结果数组的对象:

{
  "data": {
    "allStates": {
      "StateName": "[{id=1, population=10000, governor=John Smith}]"
    }
  }
}

但是,虽然这可能会指出您遇到的错误,但这是StateName从您的原始问题返回的,我认为您希望通过组合响应中的记录以进行一些优化以及一些潜在的过滤来做更多的事情。一种方法是创建一个数组(或者您可以创建一个地图 {})并根据某些条件填充它。例如,修改您的查询以将 aStateName作为参数:

type Query {
    allStates(StateName: String!): Post
}

然后,您可以在解析器响应模板中对此进行过滤,方法是使用 a#foreach和条件,然后仅在响应中的项目符合您请求的状态时才#if()调用:.add()

#set($convert = {"StateName" : [] })
#foreach($item in $ctx.result.items)
  #if($item["StateName"]=="$ctx.args.StateName")
    $util.qr($convert.get("StateName").add("$item"))
  #end
#end
$util.toJson($convert)

所以现在你可以运行这样的东西:

query {
  allStates(StateName:"Texas"){
    StateName
  }
}

这将只返回您作为参数传递的特定状态的结果。但是您会注意到查询的选择集是StateName. 您可以通过在 GraphQL 类型中列出可能的状态来引入更多的灵活性:

type State {
    StateName: String
    Seattle: String
    Texas: String
}

现在您更改解析器响应模板以使用参数来构建返回数组,因为它可以在选择集中指定它:

#set($convert = {"$ctx.args.StateName" : [] })
#foreach($item in $ctx.result.items)
  #if($item["StateName"]=="$ctx.args.StateName")
    $util.qr($convert.get("$ctx.args.StateName").add("$item"))
  #end
#end
$util.toJson($convert)

所以我可以运行这个查询:

query {
  allPosts(StateName:"Seattle"){
    Seattle
  }
}

我得到了我的结果。请注意,虽然Seattle作为参数传递但请求返回Texas

query {
  allPosts(StateName:"Seattle"){
    Texas
  }
}

这不会像您在地图中创建的响应对象一样起作用,Seattle: [...]但您将Texas其作为选择集。

您可能想要做的最后一件事是返回多个状态,您可以通过构建一个以状态名称为键的巨型地图来实现,或者通过将状态名称添加到返回类型来使用参数或选择集来完成如上所示。这取决于你,所以我不确定你会如何想要它,但希望这能展示你如何操纵响应来满足你的需求。

于 2018-04-08T22:32:10.763 回答