使用查询从DynamoDB检索所有项目？

Question

我正在尝试使用查询检索dynamodb表中的所有项。下面是我的代码：

import boto.dynamodb2
from boto.dynamodb2.table import Table
from time import sleep

c    = boto.dynamodb2.connect_to_region(aws_access_key_id="XXX",aws_secret_access_key="XXX",region_name="us-west-2")

tab  = Table("rip.irc",connection=c)

x    = tab.query()

for i in x:
    print i
    sleep(1)

但是，我收到以下错误：

ValidationException: ValidationException: 400 Bad Request
{'message': 'Conditions can be of length 1 or 2 only', '__type': 'com.amazon.coral.validate#ValidationException'}

我的代码非常简单，出自boto dynamodb2文档，因此我不确定为什么会出现上述错误。任何见解都将受到赞赏（这是新的，有点迷失）。谢谢

编辑：我有一个散列键和一个范围键。我能够通过特定的哈希键进行查询。例如

x = tab.query(hash__eq="2014-01-20 05:06:29")

但我如何检索所有项目？

Answer 1

.scan（）不会由于表分页而自动返回表的所有元素。存在1Mb最大响应限制Dynamodb最大响应限制

下面是boto3扫描的递归实现：

import boto3
dynamo = boto3.resource('dynamodb')


def scanRecursive(tableName, **kwargs):
        """
        NOTE: Anytime you are filtering by a specific equivalency attribute such as id, name 
        or date equal to ... etc., you should consider using a query not scan

        kwargs are any parameters you want to pass to the scan operation
        """
        dbTable = dynamo.Table(tableName)
        response = dbTable.scan(**kwargs)
        if kwargs.get('Select')=="COUNT":
            return response.get('Count')
        data = response.get('Items')
        while 'LastEvaluatedKey' in response:
            response = kwargs.get('table').scan(ExclusiveStartKey=response['LastEvaluatedKey'], **kwargs)
            data.extend(response['Items'])
        return data

Answer 2

我在用groovy，但它会给你一个提示。错误：

{'message': 'Conditions can be of length 1 or 2 only'}

告诉你你的关键条件是长度1-

    String keyQuery = " hashKey = :hashKey and rangeKey between :start and :end "
    queryRequest.setKeyConditionExpression(keyQuery)// define key query
    String filterExpression = " yourParam = :yourParam "
    queryRequest.setFilterExpression(filterExpression)// define filter expression
    queryRequest.setExpressionAttributeValues(expressionAttributeValues)
    queryRequest.setSelect('ALL_ATTRIBUTES')
    QueryResult queryResult = client.query(queryRequest)

Answer 3

啊，好吧，算了。如果有人需要：

如果不指定特定的哈希键，则无法对表使用查询方法。取而代之的方法是扫描。因此，如果我替换：

x    = tab.query()

具有

x    = tab.scan()

我把所有的东西都放在桌子上。