djm script for dataproc initial commit

.gitlab/package_build/installer.yml

@@ -105,6 +105,7 @@ installer-install-scripts:
     - mkdir -p $OMNIBUS_PACKAGE_DIR
     - inv -e installer.build-linux-script "databricks" "$RELEASE_VERSION"
     - inv -e installer.build-linux-script "emr" "$RELEASE_VERSION"
+    - inv -e installer.build-linux-script "dataproc" "$RELEASE_VERSION"
     - mv ./bin/installer/install-*.sh $OMNIBUS_PACKAGE_DIR/
     - ls -la $OMNIBUS_PACKAGE_DIR
   artifacts:

pkg/fleet/installer/setup/djm/dataproc.go

@@ -0,0 +1,107 @@
+// Unless explicitly stated otherwise all files in this repository are licensed
+// under the Apache License Version 2.0.
+// This product includes software developed at Datadog (https://www.datadoghq.com/).
+// Copyright 2016-present Datadog, Inc.
+
+// Package djm contains data-jobs-monitoring installation logic
+package djm
+
+import (
+	"cloud.google.com/go/compute/metadata"
+	"context"
+	"fmt"
+	"os"
+
+	"github.com/DataDog/datadog-agent/pkg/fleet/installer/setup/common"
+	"github.com/DataDog/datadog-agent/pkg/util/log"
+)
+
+const (
+	dataprocInjectorVersion   = "0.26.0-1"
+	dataprocJavaTracerVersion = "1.42.2-1"
+	dataprocAgentVersion      = "7.58.2-1"
+)
+
+var (
+	tracerEnvConfigDataproc = []common.InjectTracerConfigEnvVar{
+		{
+			Key:   "DD_DATA_JOBS_ENABLED",
+			Value: "true",
+		},
+		{
+			Key:   "DD_INTEGRATIONS_ENABLED",
+			Value: "false",
+		},
+		{
+			Key:   "DD_DATA_JOBS_COMMAND_PATTERN",
+			Value: ".*org.apache.spark.deploy.*",
+		},
+		{
+			Key:   "DD_SPARK_APP_NAME_AS_SERVICE",
+			Value: "true",
+		},
+	}
+)
+
+// SetupDataproc sets up the DJM environment on Dataproc
+func SetupDataproc(s *common.Setup) error {
+
+	metadataClient := metadata.NewClient(nil)
+	s.Packages.Install(common.DatadogAgentPackage, dataprocAgentVersion)
+	s.Packages.Install(common.DatadogAPMInjectPackage, dataprocInjectorVersion)
+	s.Packages.Install(common.DatadogAPMLibraryJavaPackage, dataprocJavaTracerVersion)
+
+	os.Setenv("DD_APM_INSTRUMENTATION_ENABLED", "host")
+
+	hostname, err := os.Hostname()
+	if err != nil {
+		return fmt.Errorf("failed to get hostname: %w", err)
+	}
+	s.Config.DatadogYAML.Hostname = hostname
+	s.Config.DatadogYAML.DJM.Enabled = true
+	s.Config.InjectTracerYAML.AdditionalEnvironmentVariables = tracerEnvConfigDataproc
+
+	// Ensure tags are always attached with the metrics
+	s.Config.DatadogYAML.ExpectedTagsDuration = "10m"
+	isMaster, clusterName, err := setupCommonDataprocHostTags(s, metadataClient)
+	if err != nil {
+		return fmt.Errorf("failed to set tags: %w", err)
+	}
+	if isMaster == "true" {
+		setupResourceManager(s, clusterName)
+	}
+	return nil
+}
+
+func setupCommonDataprocHostTags(s *common.Setup, metadataClient *metadata.Client) (string, string, error) {
+	ctx := context.Background()
+
+	clusterID, err := metadataClient.InstanceAttributeValueWithContext(ctx, "dataproc-cluster-uuid")
+	if err != nil {
+		return "", "", err
+	}
+	setHostTag(s, "cluster_id", clusterID)
+
+	dataprocRole, err := metadataClient.InstanceAttributeValueWithContext(ctx, "dataproc-role")
+	if err != nil {
+		return "", "", err
+	}
+	isMaster := "false"
+	if dataprocRole == "Master" {
+		isMaster = "true"
+	}
+	setHostTag(s, "is_master_node", isMaster)
+	s.Span.SetTag("host_tag."+"is_master_node", isMaster)
+
+	clusterName, err := metadataClient.InstanceAttributeValueWithContext(ctx, "dataproc-cluster-name")
+	if err != nil {
+		log.Warn("failed to get clusterName, using clusterID instead")
+		return isMaster, clusterID, nil
+	}
+	setHostTag(s, "cluster_name", clusterName)
+
+	//setHostTag(s, "dataproc_version", extraInfo.ReleaseLabel)
+	//s.Span.SetTag("dataproc_version", extraInfo.ReleaseLabel)
+
+	return isMaster, clusterName, nil
+}

pkg/fleet/installer/setup/djm/emr.go

@@ -96,7 +96,7 @@ func SetupEmr(s *common.Setup) error {
 		return fmt.Errorf("failed to set tags: %w", err)
 	}
 	if isMaster {
-		setupEmrResourceManager(s, clusterName)
+		setupResourceManager(s, clusterName)
 	}
 	return nil
 }
@@ -131,13 +131,13 @@ func setupCommonEmrHostTags(s *common.Setup) (bool, string, error) {
 	setHostTag(s, "emr_version", extraInfo.ReleaseLabel)
 	s.Span.SetTag("emr_version", extraInfo.ReleaseLabel)
 
-	clusterName := resolveClusterName(s, extraInfo.JobFlowID)
+	clusterName := resolveEmrClusterName(s, extraInfo.JobFlowID)
 	setHostTag(s, "cluster_name", clusterName)
 
 	return info.IsMaster, clusterName, nil
 }
 
-func setupEmrResourceManager(s *common.Setup, clusterName string) {
+func setupResourceManager(s *common.Setup, clusterName string) {
 
 	var sparkIntegration common.IntegrationConfig
 	var yarnIntegration common.IntegrationConfig
@@ -179,7 +179,7 @@ var executeCommandWithTimeout = func(s *common.Setup, command string, args ...st
 	return output, nil
 }
 
-func resolveClusterName(s *common.Setup, jobFlowID string) string {
+func resolveEmrClusterName(s *common.Setup, jobFlowID string) string {
 	var err error
 	span, _ := telemetry.StartSpanFromContext(s.Ctx, "resolve.cluster_name")
 	defer func() { span.Finish(err) }()

pkg/fleet/installer/setup/djm/emr_test.go

@@ -21,10 +21,10 @@ import (
 	"github.com/DataDog/datadog-agent/pkg/fleet/telemetry"
 )
 
-//go:embed testdata/instance.json
+//go:embed testdata/emrInstance.json
 var instanceJSON string
 
-//go:embed testdata/extraInstanceData.json
+//go:embed testdata/emrExtraInstanceData.json
 var extraInstanceJSON string
 
 //go:embed testdata/emrDescribeClusterResponse.json

pkg/fleet/installer/setup/setup.go

@@ -26,6 +26,7 @@ type flavor struct {
 var flavors = map[string]flavor{
 	"databricks": {path: "djm/databricks.go", run: djm.SetupDatabricks},
 	"emr":        {path: "djm/emr.go", run: djm.SetupEmr},
+	"dataproc":   {path: "djm/dataproc.go", run: djm.SetupDataproc},
 }
 
 // Setup installs Datadog.