Go AWS SDK的dynamodb.ScanPages能否设置等效CLI的page-size参数？

结论 #

Go AWS SDK 中与 AWS CLI page-size 参数完全等效的配置是 ScanInput 结构体的 Limit 字段。

逻辑说明 #

1. AWS CLI 的 page-size 底层逻辑是控制单次调用 DynamoDB Scan API 时请求的最大评估条目数，CLI 内部会自动处理分页游标 LastEvaluatedKey 循环拉取所有页的结果，最终拼接后返回给用户，不会限制整体扫描的总条目数。
2. Go SDK 的 ScanPages 方法逻辑与 CLI 完全对齐：你只需在传入的 ScanInput 中设置 Limit 值，SDK 每次底层调用 Scan API 都会携带该参数，单次请求最多评估对应数量的条目，内部自动处理分页逻辑，直到扫描完成或者你主动终止遍历。

代码示例 #

import (
    "context"
    "log"
    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/config"
    "github.com/aws/aws-sdk-go-v2/service/dynamodb"
)

func main() {
    // 初始化 DynamoDB 客户端
    cfg, err := config.LoadDefaultConfig(context.TODO(), config.WithRegion("us-east-1"))
    if err != nil {
        log.Fatalf("加载AWS配置失败: %v", err)
    }
    svc := dynamodb.NewFromConfig(cfg)

    // 构造扫描请求，Limit 即等效于 CLI 的 --page-size 参数，示例设置为100
    input := &dynamodb.ScanInput{
        TableName: aws.String("你的表名"),
        Limit:     aws.Int32(100),
        // 可按需添加过滤表达式、投影表达式等其他参数
    }

    // 遍历所有分页结果
    err = svc.ScanPages(context.TODO(), input, func(page *dynamodb.ScanOutput, lastPage bool) bool {
        // 处理当前页的条目
        log.Printf("当前页获取到%d条匹配结果", len(page.Items))
        // 返回true继续遍历下一页，返回false即可终止扫描
        return !lastPage
    })
    if err != nil {
        log.Fatalf("扫描表失败: %v", err)
    }
}

常见疑惑澄清 #

你看到的Limit参数说明「待评估的最大条目数（不一定是匹配的条目数量）」是DynamoDB API的原生行为，CLI的page-size底层也是传的这个参数，两者表现完全一致：如果扫描携带了过滤表达式，单次请求返回的匹配条目数可能少于你设置的Limit值，因为部分评估的条目被过滤规则排除，这属于正常表现。
如果需要限制整体扫描返回的总条目数，可以在ScanPages的回调函数里自行计数，达到阈值后返回false即可终止遍历，不会继续拉取后续页。

内容的提问来源于stack exchange，提问作者Flynn81