代码之家 › 专栏 › 技术社区 › Prasanna Nandakumar

Dynamodb扫描停止,结果返回LastEvaluatedKey

aws-api-gateway amazon-dynamodb amazon-web-services python

-1

Prasanna Nandakumar · 技术社区 · 7 年前

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

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)))

2 回复 | 直到 7 年前

Pseudonymous 7 年前

https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_Scan.html

如果扫描的项目总数超过最大数据集大小限制为1 MB时,扫描停止并将结果返回给用户一个LastEvaluatedKey值,用于在随后的操作。结果还包括超过标准的项目数限制。扫描可能导致没有符合筛选条件的表数据。

排他性启动键 操作将评估。使用为返回的值上次操作中的LastEvaluatedKey。

ExclusiveStartKey的数据类型必须是字符串、数字或二进制。不允许设置数据类型。

在并行扫描技术中,一种包括ExclusiveStartKey的扫描请求必须指定上一次扫描返回 LastEvaluatedKey的对应值。

类型:字符串到AttributeValue对象映射

密钥长度约束:最大长度为65535。

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

while 'LastEvaluatedKey' in response:
    response = table.scan(
        ProjectionExpression=pe,
        FilterExpression=fe,
        ExpressionAttributeNames= ean,
        ExclusiveStartKey=response['LastEvaluatedKey']
        )

-1

Prasanna Nandakumar 7 年前

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)
    }

推荐文章

hallibut · Lambda功能不工作的SST热重新加载

8 月前

Tim · 在java中,有没有更快的方法将字节数组写入文件?

8 月前

Tom McLean · 如何使用证书管理器制作的证书在AWS上创建到mongodb实例的TLS/SSL连接?健康检查失败

8 月前

Nuñito Calzada · AWS SDK 1.12.780 Java版的凭据

9 月前

Sampgun · CDN调用与lambda调用的巨大差异

10 月前

Mario MateaÈ · 无法从Elastic Beanstalk的EC2实例访问外部MongoDB Atlas数据库

10 月前

Tiago · 如何允许从一个安全组到另一个组的所有流量?

1 年前

Ercan Koc · 使用EKS和RDS Aurora在My VPC中努力切换到IPv6

1 年前

Andrew · CloudWatch错误:规则JobFailureRule应在堆栈范围内创建,但找不到堆栈

1 年前

explorer · AWS SageMaker项目模板创建失败

1 年前