https://github.com/kedacore/keda/issues/2214

pkg/scalers/aws_sigv4.go

@@ -5,7 +5,10 @@ import (
 	"net/http"
 	"time"
 
+	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/aws/credentials"
+	"github.com/aws/aws-sdk-go/aws/session"
+
 	v4 "github.com/aws/aws-sdk-go/aws/signer/v4"
 )
 
@@ -51,17 +54,15 @@ func NewSigV4RoundTripper(triggerMetadata map[string]string, next http.RoundTrip
 		return nil, fmt.Errorf("awsRegion not configured in trigger metadata")
 	}
 
-	accessId := triggerMetadata["awsAccessId"]
-	if accessId == "" {
-		return nil, fmt.Errorf("accessId not configured in trigger metadata")
+	sessionConfig := aws.Config{}
+	session, err := session.NewSession(&sessionConfig)
+	if err != nil {
+		return nil, fmt.Errorf("Unable to get a new AWS session")
 	}
 
-	secretKey := triggerMetadata["awsSecretKey"]
-	if secretKey == "" {
-		return nil, fmt.Errorf("secretKey not configured in trigger metadata")
-	}
+	var creds *credentials.Credentials
+	creds = session.Config.Credentials
 
-	creds := credentials.NewStaticCredentials(accessId, secretKey, "")
 	signer := v4.NewSigner(creds)
 
 	rt := &roundTripper{