首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >LastEvaluatedKey将返回Dynamodb扫描停止和结果

LastEvaluatedKey将返回Dynamodb扫描停止和结果
EN

Stack Overflow用户
提问于 2018-10-11 09:38:39
回答 2查看 5.5K关注 0票数 0

我有一个http端点-当我用我的表名作为查询字符串参数到达端点时,我只得到了LastEvaluatedKey的部分结果。

代码语言:javascript
复制
import boto3
import json

print('Loading function')
dynamo = boto3.client('dynamodb')


def respond(err, res=None):
    return {
        'statusCode': '400' if err else '200',
        'body': err.message if err else json.dumps(res),
        'headers': {
            'Content-Type': 'application/json',
        },
    }


def lambda_handler(event, context):

    operations = {
        'DELETE': lambda dynamo, x: dynamo.delete_item(**x),
        'GET': lambda dynamo, x: dynamo.scan(**x),
        'POST': lambda dynamo, x: dynamo.put_item(**x),
        'PUT': lambda dynamo, x: dynamo.update_item(**x),
    }

    operation = event['httpMethod']
    if operation in operations:
        payload = event['queryStringParameters'] if operation == 'GET' else json.loads(event['body'])
        return respond(None, operations[operation](dynamo, payload))
    else:
        return respond(ValueError('Unsupported method "{}"'.format(operation)))

如何确保扫描表格的所有页面。

EN

回答 2

Stack Overflow用户

回答已采纳

发布于 2018-10-11 09:47:00

Scan.html

如果扫描项目的总数超过1MB的最大数据集大小限制,则将停止扫描并将结果作为LastEvaluatedKey值返回给用户,以便在后续操作中继续扫描。结果还包括超过限值的物品数量。扫描可能导致没有符合筛选标准的表数据。

您需要请求,提供LastEvaluatedKey。

ExclusiveStartKey是此操作将评估的第一项的主键。使用上一次操作中为LastEvaluatedKey返回的值。 ExclusiveStartKey的数据类型必须是字符串、数字或二进制。不允许设置数据类型。 在并行扫描中,包含ExclusiveStartKey的扫描请求必须指定先前扫描返回相应的LastEvaluatedKey值的同一段。 类型:字符串到AttributeValue对象映射 键长度约束:最大长度为65535。 要求:否

循环的代码示例和从https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/GettingStarted.Python.04.html#GettingStarted.Python.04.Scan进行检查

代码语言:javascript
复制
while 'LastEvaluatedKey' in response:
    response = table.scan(
        ProjectionExpression=pe,
        FilterExpression=fe,
        ExpressionAttributeNames= ean,
        ExclusiveStartKey=response['LastEvaluatedKey']
        )
票数 3
EN

Stack Overflow用户

发布于 2018-10-11 11:48:34

代码语言:javascript
复制
import boto3
import json
import re

def lambda_handler(event, context):
    dynamodb = boto3.resource('dynamodb')
    table = dynamodb.Table('master')

    response = table.scan()
    data = response['Items']

    while 'LastEvaluatedKey' in response:
        response = table.scan(ExclusiveStartKey=response['LastEvaluatedKey'])
        data.extend(response['Items'])

    return {
        'statusCode': 200,
        'headers': {
            'Access-Control-Allow-Origin' : '*',
        },
        'body': json.dumps(data)
    }
票数 -1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/52756888

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档