primaryKey を指定して sortKey で Sort したい

tkt 2021/04/25

AppSync の Resolver をいい感じに設定してあげないといけなさそう

tkt 2021/04/25

"scanIndexForward": false.
を指定するらしい

sortのためには

tkt 2021/04/25

ここの書き方で PK と SK 使えないかな

tkt 2021/04/25

直接関係ないけど Resolver についてがわかりやすそう

tkt 2021/04/26に更新

#set( $limit = $util.defaultIfNull($context.args.limit, 100) )
#set( $modelQueryExpression = {} )

#if( !$util.isNull($ctx.args.filter.Id) && !$util.isNull($ctx.args.filter.Id.eq) )
  #set( $modelQueryExpression.expression = "#Id = :Id" )
  #set( $modelQueryExpression.expressionNames = {
  "#Id": "Id"
} )
  #set( $modelQueryExpression.expressionValues = {
  ":Id": {
      "S": "$ctx.args.filter.Id.eq"
  }
} )
#end

#set( $ListRequest = {
  "version": "2018-05-29",
  "limit": $limit,
  "operation": "Query"
} )
#if( $context.args.nextToken )
  #set( $ListRequest.nextToken = $context.args.nextToken )
#end

$util.qr($ListRequest.put("query", $modelQueryExpression))
#set( $ListRequest.scanIndexForward = false )

$util.toJson($ListRequest)

Id 一致で降順でとってくる

tkt 2021/04/25

query ListPosts(
    $filter: TablePostsFilterInput
    $limit: Int
    $nextToken: String
)

クエリはこんな感じ

tkt 2021/04/25

query ListPosts(
    $filter: TablePostsFilterInput
    $limit: Int
    $nextToken: String
)

クエリはこんな感じ

tkt 2021/04/25

ここ参考にして書いた

tkt 2021/04/26

通ったクエリをおいておく

#set( $limit = $util.defaultIfNull($context.args.limit, 100) )
#set( $QueryRequest = {
  "version": "2017-02-28",
  "operation": "Scan",
  "limit": $limit
} )
#if( $context.args.nextToken ) #set( $QueryRequest.nextToken = "$context.args.nextToken" ) #end
#if( $context.args.filter ) #set( $QueryRequest.filter = $util.parseJson("$util.transform.toDynamoDBFilterExpression($ctx.args.filter)") ) #end
$util.toJson($QueryRequest)

tkt 2021/04/26

#set( $limit = $util.defaultIfNull($context.args.limit, 100) )

#set( $modelQueryExpression = {} )

#if( !$util.isNull($ctx.args.filter.id) && !$util.isNull($ctx.args.filter.id.eq) )
  #set( $modelQueryExpression.expression = "#id = :id" )
  #set( $modelQueryExpression.expressionNames = {
  "#id": "id"
} )
  #set( $modelQueryExpression.expressionValues = {
  ":id": {
      "S": "$ctx.args.filter.id.eq"
  }
} )
#end

#set( $QueryRequest = {
  "version": "2017-02-28",
  "limit": $limit
} )
#if( $context.args.nextToken ) #set( $QueryRequest.nextToken = "$context.args.nextToken" ) #end
#if( $context.args.filter ) #set( $QueryRequest.filter = $util.parseJson("$util.transform.toDynamoDBFilterExpression($ctx.args.filter)") ) #end
$util.qr($ListRequest.put("query", $modelQueryExpression))
#if( !$util.isNull($ctx.args.filter.id) && !$util.isNull($ctx.args.filter.id.eq) )
  #set( $QueryRequest.operation = "Query" )
  #set( $ListRequest.scanIndexForward = false )
#else
  #set( $QueryRequest.operation = "Scan" )
#end
$util.toJson($QueryRequest)

動いた

tkt 2021/04/26

動いてなかった

tkt 2021/04/28に更新

## limit が設定されていなければ 100 にする
#set( $limit = $util.defaultIfNull($context.args.limit, 100) )

#set( $modelQueryExpression = {} )

## filter に id の一致検索が入っていたら、クエリを作る
#if( !$util.isNull($ctx.args.filter.id) && !$util.isNull($ctx.args.filter.id.eq) )
  #set( $modelQueryExpression.expression = "#id = :id" )
  #set( $modelQueryExpression.expressionNames = {
  "#id": "id"
} )
  #set( $modelQueryExpression.expressionValues = {
  ":id": {
      "S": "$context.args.filter.id.eq"
  }
} )
#end

#set( $QueryRequest = {
  "version": "2017-02-28",
  "limit": $limit
} )
#if( $context.args.nextToken )
  #set( $QueryRequest.nextToken = "$context.args.nextToken" )
#end

#if( $context.args.filter )
  #set( $QueryRequest.filter = $util.parseJson("$util.transform.toDynamoDBFilterExpression($context.args.filter)") )
#end

$util.qr($ListRequest.put("query", $modelQueryExpression))

## id の一致指定があれば Query, なければ Scan を投げる
#if( !$util.isNull($ctx.args.filter.id) && !$util.isNull($context.args.filter.id.eq) )
  #set( $QueryRequest.operation = "Query" )
  #set( $ListRequest.scanIndexForward = false )
#else
  #set( $QueryRequest.operation = "Scan" )
#end

$util.toJson($QueryRequest)

ctx -> context

tkt 2021/04/28に更新

#set( $limit = $util.defaultIfNull($context.args.limit, 100) )

#set( $modelQueryExpression = {} )

#if( !$util.isNull($context.args.filter.id) && !$util.isNull($context.args.filter.id.eq) )
  #set( $modelQueryExpression.expression = "#id = :id" )
  #set( $modelQueryExpression.expressionNames = {
    "#id": "id"
  } )
  #set( $modelQueryExpression.expressionValues = {
    ":id": {
        "S": "$context.args.filter.id.eq"
    }
  } )
#end

#if( !$util.isNull($context.args.filter.timestampMs) && !$util.isNull($context.args.filter.timestampMs.eq) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey = :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestampMs"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$context.args.filter.timestampMs.eq" }))
#end
#if( !$util.isNull($context.args.filter.timestampMs) && !$util.isNull($context.args.filter.timestampMs.ge) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey >= :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestampMs"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$context.args.filter.timestampMs.ge" }))
#end

#set( $QueryRequest = {
  "version": "2017-02-28",
  "limit": $limit
} )

#if( $context.args.nextToken )
  #set( $QueryRequest.nextToken = "$context.args.nextToken" )
#end

#if( !$util.isNull($context.args.filter.id) && !$util.isNull($context.args.filter.id.eq) )
  #set( $QueryRequest.operation = "Query" )
  #set( $QueryRequest.scanIndexForward = false )
  $util.qr($QueryRequest.put("query", $modelQueryExpression))
#else
  #set( $QueryRequest.operation = "Scan" )
#end

$util.toJson($QueryRequest)

sortKey の指定を入れた

tkt 2021/04/28に更新

"S": "$context.args.filter.id.eq"

この S とか N とか何かと思ってたら、
String, Number か

tkt 2021/04/30に更新

#set( $limit = $util.defaultIfNull($context.args.limit, 100) )

#set( $modelQueryExpression = {} )

#if( !$util.isNull($context.args.filter.id) && !$util.isNull($context.args.filter.id.eq) )
  #set( $modelQueryExpression.expression = "#id = :id" )
  #set( $modelQueryExpression.expressionNames = {
    "#id": "id"
  } )
  #set( $modelQueryExpression.expressionValues = {
    ":id": {
        "S": "$context.args.filter.id.eq"
    }
  } )
#end

#if( !$util.isNull($context.args.filter.timestampMs) && !$util.isNull($context.args.filter.timestampMs.eq) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey = :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestampMs"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$context.args.filter.timestampMs.eq" }))
#end
#if( !$util.isNull($context.args.filter.timestampMs) && !$util.isNull($context.args.filter.timestampMs.ge) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey >= :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestampMs"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$context.args.filter.timestampMs.ge" }))
#end

#set( $QueryRequest = {
  "version": "2017-02-28",
  "limit": $limit
} )

#if( $context.args.nextToken )
  #set( $QueryRequest.nextToken = "$context.args.nextToken" )
#end

#if( !$util.isNull($context.args.filter.id) && !$util.isNull($context.args.filter.id.eq) )
  #set( $QueryRequest.operation = "Query" )
  #set( $QueryRequest.scanIndexForward = false )
  $util.qr($QueryRequest.put("query", $modelQueryExpression))
#else
  #set( $QueryRequest.operation = "Scan" )
  #set( $QueryRequest.filter =  #if($context.args.filter) $util.transform.toDynamoDBFilterExpression($context.args.filter) #else null #end)
#end

$util.toJson($QueryRequest)

ScanのときにFilterを使うように

何かがだめっぽい

#set( $limit = $util.defaultIfNull($context.args.limit, 100) )

#set( $modelQueryExpression = {} )

#if( !$util.isNull($context.args.filter.id) && !$util.isNull($context.args.filter.id.eq) )
  #set( $modelQueryExpression.expression = "#id = :id" )
  #set( $modelQueryExpression.expressionNames = {
  "#id": "id"
} )
  #set( $modelQueryExpression.expressionValues = {
  ":id": {
      "S": "$context.args.filter.id.eq"
  }
} )
#end

#if( !$util.isNull($context.args.filter.timestampMs) && !$util.isNull($context.args.filter.timestampMs.eq) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey = :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestampMs"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$context.args.filter.timestampMs.eq" }))
#end
#if( !$util.isNull($context.args.filter.timestampMs) && !$util.isNull($context.args.filter.timestampMs.ge) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey >= :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestampMs"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$context.args.filter.timestampMs.ge" }))
#end

#set( $QueryRequest = {
  "version": "2017-02-28",
  "limit": $limit
} )

#if( $context.args.nextToken ) #set( $QueryRequest.nextToken = "$context.args.nextToken" ) #end

#if( !$util.isNull($context.args.filter.id) )
  #set( $QueryRequest.operation = "Query" )
  #set( $QueryRequest.scanIndexForward = false )
  $util.qr($QueryRequest.put("query", $modelQueryExpression))
#else
  #set( $QueryRequest.operation = "Scan" )
#end

#if( !$util.isNull($context.args.filter) )
 $util.qr( $QueryRequest.put("filter", $util.transform.toDynamoDBFilterExpression($context.args.filter)) )
#end

$util.toJson($QueryRequest)

{
  "data": {
    "xxxxxxxxxxxx": null
  },
  "errors": [
    {
      "path": [
        "xxxxxxxxxxxx"
      ],
      "data": null,
      "errorType": "MappingTemplate",
      "errorInfo": null,
      "locations": [
        {
          "line": 2,
          "column": 3,
          "sourceName": null
        }
      ],
      "message": "Expected JSON object for '$[filter]' but got a 'STRING' instead."
    }
  ]
}

何が違うのかがわからない

tkt 2021/05/04

#set( $limit = $util.defaultIfNull($context.args.limit, 100) )

#set( $modelQueryExpression = {} )

#if( !$util.isNull($context.args.filter.id) && !$util.isNull($context.args.filter.id.eq) )
  #set( $modelQueryExpression.expression = "#id = :id" )
  #set( $modelQueryExpression.expressionNames = {
  "#id": "id"
} )
  #set( $modelQueryExpression.expressionValues = {
  ":id": {
      "S": "$context.args.filter.id.eq"
  }
} )
#end

#if( !$util.isNull($context.args.filter.timestampMs) && !$util.isNull($context.args.filter.timestampMs.eq) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey = :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestampMs"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$context.args.filter.timestampMs.eq" }))
#end
#if( !$util.isNull($context.args.filter.timestampMs) && !$util.isNull($context.args.filter.timestampMs.ge) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey >= :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestampMs"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$context.args.filter.timestampMs.ge" }))
#end

#set( $QueryRequest = {
  "version": "2017-02-28",
  "limit": $limit
} )

#if( $context.args.nextToken ) #set( $QueryRequest.nextToken = "$context.args.nextToken" ) #end

#if( !$util.isNull($context.args.filter.id) )
  #set( $QueryRequest.operation = "Query" )
  #set( $QueryRequest.scanIndexForward = false )
  $util.qr($QueryRequest.put("query", $modelQueryExpression))
#else
  #set( $QueryRequest.operation = "Scan" )
#end

#if( $context.args.filter ) #set( $QueryRequest.filter = $util.parseJson("$util.transform.toDynamoDBFilterExpression($ctx.args.filter)") ) #end

$util.toJson($QueryRequest)

tkt 2021/05/04

通った

tkt 2021/05/04

だめだ。クエリが効かなくなった

tkt 2021/05/04

"Filter Expression can only contain non-primary key attributes: Primary key attribute: id (Service: DynamoDb, Status Code: 400, Request ID: XXXXXX, Extended Request ID: null)"

filter から primary key を外せってことかな

tkt 2021/05/04

#set( $limit = $util.defaultIfNull($context.args.limit, 100) )

#set( $modelQueryExpression = {} )

#if( !$util.isNull($context.args.filter.id) && !$util.isNull($context.args.filter.id.eq) )
  #set( $modelQueryExpression.expression = "#id = :id" )
  #set( $modelQueryExpression.expressionNames = {
  "#id": "id"
} )
  #set( $modelQueryExpression.expressionValues = {
  ":id": {
      "S": "$context.args.filter.id.eq"
  }
} )
#end

#if( !$util.isNull($context.args.filter.timestampMs) && !$util.isNull($context.args.filter.timestampMs.eq) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey = :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestampMs"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$context.args.filter.timestampMs.eq" }))
#end
#if( !$util.isNull($context.args.filter.timestampMs) && !$util.isNull($context.args.filter.timestampMs.ge) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey >= :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestampMs"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$context.args.filter.timestampMs.ge" }))
#end

#set( $QueryRequest = {
  "version": "2017-02-28",
  "limit": $limit
} )

#if( $context.args.nextToken ) #set( $QueryRequest.nextToken = "$context.args.nextToken" ) #end

#if( !$util.isNull($context.args.filter.id) )
  #set( $QueryRequest.operation = "Query" )
  #set( $QueryRequest.scanIndexForward = false )
  $util.qr($QueryRequest.put("query", $modelQueryExpression))
#else
  #set( $QueryRequest.operation = "Scan" )
  #if( $context.args.filter ) #set( $QueryRequest.filter = $util.parseJson("$util.transform.toDynamoDBFilterExpression($ctx.args.filter)") ) #end
#end

$util.toJson($QueryRequest)

scan のときだけ filter を呼び出す妥協案

tkt 2021/05/04

query のときも付加条件で filter したい

tkt 2021/05/04

全部 filter でやろうとしてるから詰まってる説

key は $context.args.id の形で
filter は $context.args.filter で取る
ってすれば、filter に key が入り込むことはなさそう

tkt 2021/05/04

このとおりに書けってこったあ

tkt 2021/05/13

## [Start] Set query expression for @key **
#set( $modelQueryExpression = {} )

#if( !$util.isNull($ctx.args.id) )
  #set( $modelQueryExpression.expression = "#id = :id" )
  #set( $modelQueryExpression.expressionNames = {
  "#id": "id"
} )
  #set( $modelQueryExpression.expressionValues = {
  ":id": {
      "S": "$ctx.args.id"
  }
} )
#end
## [Start] Applying Key Condition **
#if( !$util.isNull($ctx.args.timestamp) && !$util.isNull($ctx.args.timestamp.beginsWith) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND begins_with(#sortKey, :sortKey)" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestamp"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$ctx.args.timestamp.beginsWith" }))
#end
#if( !$util.isNull($ctx.args.timestamp) && !$util.isNull($ctx.args.timestamp.between) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey BETWEEN :sortKey0 AND :sortKey1" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestamp"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey0", { "N": "$ctx.args.timestamp.between[0]" }))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey1", { "N": "$ctx.args.timestamp.between[1]" }))
#end
#if( !$util.isNull($ctx.args.timestamp) && !$util.isNull($ctx.args.timestamp.eq) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey = :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestamp"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$ctx.args.timestamp.eq" }))
#end
#if( !$util.isNull($ctx.args.timestamp) && !$util.isNull($ctx.args.timestamp.lt) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey < :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestamp"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$ctx.args.timestamp.lt" }))
#end
#if( !$util.isNull($ctx.args.timestamp) && !$util.isNull($ctx.args.timestamp.le) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey <= :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestamp"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$ctx.args.timestamp.le" }))
#end
#if( !$util.isNull($ctx.args.timestamp) && !$util.isNull($ctx.args.timestamp.gt) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey > :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestamp"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$ctx.args.timestamp.gt" }))
#end
#if( !$util.isNull($ctx.args.timestamp) && !$util.isNull($ctx.args.timestamp.ge) )
  #set( $modelQueryExpression.expression = "$modelQueryExpression.expression AND #sortKey >= :sortKey" )
  $util.qr($modelQueryExpression.expressionNames.put("#sortKey", "timestamp"))
  $util.qr($modelQueryExpression.expressionValues.put(":sortKey", { "N": "$ctx.args.timestamp.ge" }))
#end
## [End] Applying Key Condition **
## [End] Set query expression for @key **
#set( $limit = $util.defaultIfNull($context.args.limit, 20) )
#set( $QueryRequest = {
  "version": "2017-02-28",
  "limit": $limit,
} )

#if( $context.args.nextToken ) #set( $QueryRequest.nextToken = "$context.args.nextToken" ) #end
#if( $context.args.filter ) #set( $QueryRequest.filter = $util.parseJson("$util.transform.toDynamoDBFilterExpression($ctx.args.filter)") ) #end

#if( !$util.isNull($context.args.id) )
  #set( $QueryRequest.operation = "Query" )
  #set( $QueryRequest.scanIndexForward = false )
  $util.qr($QueryRequest.put("query", $modelQueryExpression))
#else
  #set( $QueryRequest.operation = "Scan" )
#end

$util.toJson($QueryRequest)

key があったら query、そうでなければ scan

このスクラップは2021/04/26にクローズされました