我有一个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)))如何确保扫描表格的所有页面。
发布于 2018-10-11 09:47:00
如果扫描项目的总数超过1MB的最大数据集大小限制,则将停止扫描并将结果作为LastEvaluatedKey值返回给用户,以便在后续操作中继续扫描。结果还包括超过限值的物品数量。扫描可能导致没有符合筛选标准的表数据。
您需要请求,提供LastEvaluatedKey。
ExclusiveStartKey是此操作将评估的第一项的主键。使用上一次操作中为LastEvaluatedKey返回的值。 ExclusiveStartKey的数据类型必须是字符串、数字或二进制。不允许设置数据类型。 在并行扫描中,包含ExclusiveStartKey的扫描请求必须指定先前扫描返回相应的LastEvaluatedKey值的同一段。 类型:字符串到AttributeValue对象映射 键长度约束:最大长度为65535。 要求:否
while 'LastEvaluatedKey' in response:
response = table.scan(
ProjectionExpression=pe,
FilterExpression=fe,
ExpressionAttributeNames= ean,
ExclusiveStartKey=response['LastEvaluatedKey']
)发布于 2018-10-11 11:48:34
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)
}https://stackoverflow.com/questions/52756888
复制相似问题