我有一个需要连接 AWS 上的 Keyspaces 的 Go 服务。我的 pod 有一个角色 and和AWS_SECRET_ACCESS_KEYenv vars。AWS_ACCESS_KEY_IDAWS_SESSION_TOKEN
我想使用 aws SDK v2。我应该使用什么凭据提供程序?ec2rolecreds或其他一个(也许stscreds)?
我试图从这里实现示例。但我得到一个错误
no EC2 IMDS role found, operation error ec2imds: GetMetadata, request canceled, context deadline exceeded
我在哪里可以找到工作示例和更多解释?
更新
现在我的代码如下所示:
awsCfg, err := awsConfig.LoadDefaultConfig(ctx)
if err != nil {
return nil, fmt.Errorf("failed to load AWS config: %w", err)
}
imdsClient := imds.NewFromConfig(awsCfg)
appCreds := aws.NewCredentialsCache(ec2rolecreds.New(func(options *ec2rolecreds.Options) {
options.Client = imdsClient
}))
cluster := gocql.NewCluster(cassandraHost)
auth := sigv4.NewAwsAuthenticator()
auth.SessionToken = value.SessionToken
auth.AccessKeyId = value.AccessKeyID
auth.SecretAccessKey = value.SecretAccessKey
cluster.Authenticator = auth
session, err := cluster.CreateSession()
Retrieve()返回错误
no EC2 IMDS role found, operation error ec2imds: GetMetadata, exceeded maximum number of attempts, 3, request send failed, Get \"http://169.254.169.254/latest/meta-data/iam/security-credentials/\": dial tcp 169.254.169.254:80: connect: host is down
更新 2
在同一环境中,AWS SDK v1 工作正常。所以物理上 AWS 端点是可用的。
session, err := aws_sess.NewSession()
if err != nil {
return fmt.Errorf("failed to create AWS session: %w", err)
}
creds := credentialsV1.NewChainCredentials(
[]credentialsV1.Provider{
&credentialsV1.EnvProvider{},
&ec2rolecredsV1.EC2RoleProvider{
Client: ec2metadataV1.New(session),
}})
value, getErr := creds.Get()