Skip to content
Snippets Groups Projects
Commit 56be3d32 authored by Adam Johnson's avatar Adam Johnson Committed by Daniel Nelson
Browse files

Reintroduce AWS credential check to cloudwatch output (#3587)

parent a440ed8d
No related branches found
No related tags found
No related merge requests found
...@@ -9,6 +9,7 @@ import ( ...@@ -9,6 +9,7 @@ import (
"github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/service/cloudwatch" "github.com/aws/aws-sdk-go/service/cloudwatch"
"github.com/aws/aws-sdk-go/service/sts"
"github.com/influxdata/telegraf" "github.com/influxdata/telegraf"
internalaws "github.com/influxdata/telegraf/internal/config/aws" internalaws "github.com/influxdata/telegraf/internal/config/aws"
...@@ -70,7 +71,20 @@ func (c *CloudWatch) Connect() error { ...@@ -70,7 +71,20 @@ func (c *CloudWatch) Connect() error {
Token: c.Token, Token: c.Token,
} }
configProvider := credentialConfig.Credentials() configProvider := credentialConfig.Credentials()
stsService := sts.New(configProvider)
params := &sts.GetCallerIdentityInput{}
_, err := stsService.GetCallerIdentity(params)
if err != nil {
log.Printf("E! cloudwatch: Cannot use credentials to connect to AWS : %+v \n", err.Error())
return err
}
c.svc = cloudwatch.New(configProvider) c.svc = cloudwatch.New(configProvider)
return nil return nil
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment