Make cloud provider metadata log more robust (#1620)

Signed-off-by: Dani Louca <[email protected]>
signalfx · Mar 5, 2021 · 8b4d34d · 8b4d34d
1 parent 27115e1
commit 8b4d34d
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 7 deletions.
diff --git a/pkg/core/hostid/aws.go b/pkg/core/hostid/aws.go
@@ -20,8 +20,8 @@ func AWSUniqueID(cloudMetadataTimeout timeutil.Duration) string {
 	resp, err := c.Get("http://169.254.169.254/2014-11-05/dynamic/instance-identity/document")
 	if err != nil {
 		log.WithFields(log.Fields{
-			"error": err,
-		}).Debug("Failed to get AWS instance-identity")
+			"detail": err,
+		}).Info("No AWS metadata server detected, assuming not on EC2")
 		return ""
 	}
 	defer resp.Body.Close()
@@ -30,7 +30,7 @@ func AWSUniqueID(cloudMetadataTimeout timeutil.Duration) string {
 	if err != nil {
 		log.WithFields(log.Fields{
 			"error": err,
-		}).Debug("Failed to read AWS instance-identity response")
+		}).Info("Failed to read AWS instance-identity response")
 		return ""
 	}
 
@@ -45,12 +45,12 @@ func AWSUniqueID(cloudMetadataTimeout timeutil.Duration) string {
 		log.WithFields(log.Fields{
 			"error": err,
 			"body":  string(body),
-		}).Debug("Failed to unmarshal AWS instance-identity response")
+		}).Info("Failed to unmarshal AWS instance-identity response")
 		return ""
 	}
 
 	if doc.AccountID == "" || doc.InstanceID == "" || doc.Region == "" {
-		log.Debugf("One (or more) required field is empty. AccountID: %s ; InstanceID: %s ; Region: %s", doc.AccountID, doc.InstanceID, doc.Region)
+		log.Errorf("One (or more) required field is empty. AccountID: %s ; InstanceID: %s ; Region: %s", doc.AccountID, doc.InstanceID, doc.Region)
 		return ""
 	}
 

diff --git a/pkg/core/hostid/azure.go b/pkg/core/hostid/azure.go
@@ -8,6 +8,7 @@ import (
 	"strings"
 
 	"github.com/signalfx/signalfx-agent/pkg/utils/timeutil"
+	log "github.com/sirupsen/logrus"
 )
 
 // AzureUniqueID constructs the unique ID of the underlying Azure VM.  If
@@ -26,6 +27,9 @@ func AzureUniqueID(cloudMetadataTimeout timeutil.Duration) string {
 	req.Header.Set("Metadata", "true")
 	resp, err := c.Do(req)
 	if err != nil {
+		log.WithFields(log.Fields{
+			"detail": err,
+		}).Infof("No Azure metadata server detected, assuming not on Azure")
 		return ""
 	}
 	defer resp.Body.Close()

diff --git a/pkg/core/hostid/gcp.go b/pkg/core/hostid/gcp.go
@@ -6,7 +6,7 @@ import (
 	"net/http"
 
 	"github.com/signalfx/signalfx-agent/pkg/utils/timeutil"
-	"github.com/sirupsen/logrus"
+	log "github.com/sirupsen/logrus"
 )
 
 // GoogleComputeID generates a unique id for the compute instance that the
@@ -41,7 +41,9 @@ func getMetadata(path string, cloudMetadataTimeout timeutil.Duration) string {
 
 	resp, err := c.Do(req)
 	if err != nil {
-		logrus.WithError(err).Debugf("Failed to query GCP Metadata endpoint at %s", url)
+		log.WithFields(log.Fields{
+			"detail": err,
+		}).Infof("No GCP metadata server detected at %s , assuming not on GCP", url)
 		return ""
 	}
 	defer resp.Body.Close()