q792602257/VptPassiveAdapter
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

s3 一次性10000个

Browse Source
This commit is contained in:
Jerry Yan 2025-04-13 18:43:45 +08:00
parent f9256895b7
commit 3d7c88de5f
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
fs/s3_adapter.go
View File

@ -56,8 +56,9 @@ func (s *S3Adapter) GetFileList(ctx context.Context, dirPath string, relDt time.
} }
listObjectsInput := &s3.ListObjectsV2Input{ listObjectsInput := &s3.ListObjectsV2Input{
Bucket: aws.String(s.StorageConfig.S3.Bucket), Bucket: aws.String(s.StorageConfig.S3.Bucket),
Prefix: aws.String(path.Join(s.StorageConfig.S3.Prefix, dirPath)), Prefix: aws.String(path.Join(s.StorageConfig.S3.Prefix, dirPath)),
MaxKeys: aws.Int32(1000),
} }
client, err := s.getClient() client, err := s.getClient()