Go语言AWS SDK v1连接本地S3失败求助：签名不匹配等错误

常见问题排查与修复方案 #

1. 强制启用路径样式访问 #

大部分本地S3兼容服务（如MinIO、Ceph RGW）不支持AWS默认的虚拟主机式桶访问规则，必须显式开启路径样式访问。在aws.Config配置中添加：

S3ForcePathStyle: aws.Bool(true),

2. 修正区域配置 #

避免使用非标准区域标识（如us-east-01），改用AWS标准区域（如us-east-1），或确保区域值与本地S3服务的配置完全一致：

Region: aws.String("us-east-1"),

3. 指定签名版本 #

部分本地S3服务仅支持v2签名，或需要显式指定签名版本。可根据服务实际情况在配置中添加：

SignatureVersion: aws.String("v4"), // 若服务仅支持v2则改为"v2"

4. 验证端点格式 #

确保端点URL包含完整协议（http/https）和端口，例如：http://localhost:9000，避免使用localhost:9000这类不完整格式。

修改后的完整代码示例 #

S3客户端实现 #

package main

import (
    "fmt"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/credentials"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/s3"
)

type S3Client struct {
    url        string
    accessKey  string
    secretKey  string
    bucketName string
}

func NewClient(endpointUrl, accessKey, secretKey, bucketName string) (S3Client, error) {
    return S3Client{
        url:        endpointUrl,
        accessKey:  accessKey,
        secretKey:  secretKey,
        bucketName: bucketName,
    }, nil
}

func (c *S3Client) ListBucketContents() {
    creds := credentials.NewStaticCredentials(c.accessKey, c.secretKey, "")
    sess, err := session.NewSession(&aws.Config{
        Credentials:      creds,
        Endpoint:         aws.String(c.url),
        Region:           aws.String("us-east-1"),
        DisableSSL:       aws.Bool(true),
        S3ForcePathStyle: aws.Bool(true),
        SignatureVersion: aws.String("v4"),
    })

    if err != nil {
        fmt.Printf("无法创建会话: %v\n", err)
        return
    }

    svc := s3.New(sess)
    resp, err := svc.ListObjectsV2(&s3.ListObjectsV2Input{
        Bucket: aws.String(c.bucketName),
    })
    if err != nil {
        fmt.Printf("无法列出桶内容 %q: %v\n", c.bucketName, err)
        return
    }

    fmt.Printf("桶 %s 下的文件列表:\n", c.bucketName)
    fmt.Println("*********************************")
    for _, item := range resp.Contents {
        fmt.Printf("文件名: %s\n", aws.StringValue(item.Key))
        fmt.Printf("最后修改时间: %v\n", item.LastModified)
        fmt.Printf("文件大小: %d bytes\n", item.Size)
        fmt.Println("---")
    }
}

主函数 #

package main

import "fmt"

func main() {
    // 替换为你的实际端点、凭证和桶名
    client, err := NewClient("http://localhost:9000", "your-access-key", "your-secret-key", "your-bucket")
    if err != nil {
        fmt.Println("客户端初始化失败")
        return
    }

    client.ListBucketContents()
}

额外检查项 #

• 确认本地S3服务正在运行，用curl测试端点可达性：curl http://localhost:9000
• 核对凭证与Python中使用的完全一致，无多余空格或拼写错误
• 若使用MinIO，确保启动时未禁用v4签名（默认支持v4）

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