AWSDynamoDB的ParallelScan结果排序问题
创始人
2024-09-24 22:30:38
0

AWS DynamoDB 的 ParallelScan 方法可以并行扫描 DynamoDB 表中的数据,但结果的排序可能不会按照用户预期的顺序排列,因为它们将被返回一致性级别和扫描使用的不同分区键影响。以下是一种可能的解决方法,通过将 ParallelScan 方法中的扫描分为多个批次并按照指定顺序对其进行排序来确保结果的顺序一致性。

示例代码:

from boto3.dynamodb.conditions import Key, Attr import boto3

要扫描的 DynamoDB 表和索引

table_name = 'my_table' index_name = 'my_index'

定义扫描的分批大小和需要排序的属性

batch_size = 100 sort_key = 'my_sort_key'

获得 DynamoDB 客户端

dynamodb = boto3.client('dynamodb')

获取分区键的总数以确定要分配的批次数

partition_count = dynamodb.describe_table(TableName=table_name)['Table']['ItemCount'] batches = partition_count // batch_size

循环遍历批次并进行并行扫描

results = [] for batch in range(batches): start_partition = batch * batch_size end_partition = start_partition + batch_size kwargs = { 'TableName': table_name, 'IndexName': index_name, 'Segment': batch, 'TotalSegments': batches, 'FilterExpression': Attr('my_attribute').eq("my_value") } response = dynamodb.scan(**kwargs)

# 将结果添加到列表中
results.extend(response['Items'])

按照指定排序键对结果进行排序

sorted_results = sorted(results, key=lambda item: item.get(sort_key))

print(sorted_results)

相关内容

热门资讯

出现新变化!福建大玩家辅助操作... 您好:福建大玩家辅助操作视频这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多用...
第九分钟开挂!微信小程序微乐挖... 第九分钟开挂!微信小程序微乐挖坑辅助免费,花花生活圈可以开挂,教你教程-2026最新版本微信小程序微...
此事引发广泛关注!三哥玩摆头注... 此事引发广泛关注!三哥玩摆头注可以控制(辅助挂)其实是有挂(有挂法门)-哔哩哔哩 【无需打开直接搜索...
九分钟开挂!皮皮透视辅助软件工... 九分钟开挂!皮皮透视辅助软件工具,皇豪互众控制系统下载,分享教程-2026最新版本1、九分钟开挂!皮...
今天上午!蜀山四川辅助脚本(辅... 今天上午!蜀山四川辅助脚本(辅助挂)一直真的有挂(有挂方案)-哔哩哔哩;亲,蜀山四川辅助脚本这款游戏...
四分钟开挂!闲逸同花插件,欢聚... 四分钟开挂!闲逸同花插件,欢聚水鱼辅助视频,必备教程-2026最新版本1、欢聚水鱼辅助视频透视辅助简...
为切实保障!牌乐门安全黑科技是... 为切实保障!牌乐门安全黑科技是真的吗(辅助挂)其实真的是有挂(有挂方针)-哔哩哔哩您好:牌乐门安全黑...
五分钟开挂!约局吧辅助器下载,... 五分钟开挂!约局吧辅助器下载,兴动互娱辅助工具,介绍教程-2026最新版本1、该软件可以轻松地帮助玩...
据了解!今日长牌破解(辅助挂)... 据了解!今日长牌破解(辅助挂)原来是有挂的(有挂机巧)-哔哩哔哩 了解更多开挂安装加(1367043...
3分钟开挂!广西老友玩友破解视... 3分钟开挂!广西老友玩友破解视频,玄龙辅助工具,教你教程-2026最新版本1)广西老友玩友破解视频辅...