Guía para el monitoreo y las alertas del Atlas

// See entire project at https://github.com/mongodb/atlas-architecture-go-sdk
package main
import (
	"context"
	"encoding/json"
	"fmt"
	"log"
	"atlas-sdk-examples/internal/auth"
	"atlas-sdk-examples/internal/config"
	"atlas-sdk-examples/internal/metrics"
	"github.com/joho/godotenv"
	"go.mongodb.org/atlas-sdk/v20250219001/admin"
)
func main() {
	envFile := ".env.development"
	if err := godotenv.Load(envFile); err != nil {
		log.Printf("Warning: could not load %s file: %v", envFile, err)
	}
	secrets, cfg, err := config.LoadAllFromEnv()
	if err != nil {
		log.Fatalf("Failed to load configuration %v", err)
	}
	ctx := context.Background()
	client, err := auth.NewClient(ctx, cfg, secrets)
	if err != nil {
		log.Fatalf("Failed to initialize authentication client: %v", err)
	}
	// Fetch disk metrics with the provided parameters
	p := &admin.GetDiskMeasurementsApiParams{
		GroupId:       cfg.ProjectID,
		ProcessId:     cfg.ProcessID,
		PartitionName: "data",
		M:             &[]string{"DISK_PARTITION_SPACE_FREE", "DISK_PARTITION_SPACE_USED"},
		Granularity:   admin.PtrString("P1D"),
		Period:        admin.PtrString("P1D"),
	}
	view, err := metrics.FetchDiskMetrics(ctx, client.MonitoringAndLogsApi, p)
	if err != nil {
		log.Fatalf("Failed to fetch disk metrics: %v", err)
	}
	// Output metrics
	out, err := json.MarshalIndent(view, "", "  ")
	if err != nil {
		log.Fatalf("Failed to format metrics data: %v", err)
	}
	fmt.Println(string(out))
}

// See entire project at https://github.com/mongodb/atlas-architecture-go-sdk
package main
import (
	"context"
	"fmt"
	"log"
	"atlas-sdk-examples/internal/auth"
	"atlas-sdk-examples/internal/config"
	"atlas-sdk-examples/internal/fileutils"
	"atlas-sdk-examples/internal/logs"
	"github.com/joho/godotenv"
	"go.mongodb.org/atlas-sdk/v20250219001/admin"
)
func main() {
	envFile := ".env.production"
	if err := godotenv.Load(envFile); err != nil {
		log.Printf("Warning: could not load %s file: %v", envFile, err)
	}
	secrets, cfg, err := config.LoadAllFromEnv()
	if err != nil {
		log.Fatalf("Failed to load configuration %v", err)
	}
	ctx := context.Background()
	client, err := auth.NewClient(ctx, cfg, secrets)
	if err != nil {
		log.Fatalf("Failed to initialize authentication client: %v", err)
	}
	// Fetch logs with the provided parameters
	p := &admin.GetHostLogsApiParams{
		GroupId:  cfg.ProjectID,
		HostName: cfg.HostName,
		LogName:  "mongodb",
	}
	fmt.Printf("Request parameters: GroupID=%s, HostName=%s, LogName=%s\n",
		cfg.ProjectID, cfg.HostName, p.LogName)
	rc, err := logs.FetchHostLogs(ctx, client.MonitoringAndLogsApi, p)
	if err != nil {
		log.Fatalf("Failed to fetch logs: %v", err)
	}
	defer fileutils.SafeClose(rc)
	// Prepare output paths
	// If the ATLAS_DOWNLOADS_DIR env variable is set, it will be used as the base directory for output files
	outDir := "logs"
	prefix := fmt.Sprintf("%s_%s", p.HostName, p.LogName)
	gzPath, err := fileutils.GenerateOutputPath(outDir, prefix, "gz")
	if err != nil {
		log.Fatalf("Failed to generate GZ output path: %v", err)
	}
	txtPath, err := fileutils.GenerateOutputPath(outDir, prefix, "txt")
	if err != nil {
		log.Fatalf("Failed to generate TXT output path: %v", err)
	}
	// Save compressed logs
	if err := fileutils.WriteToFile(rc, gzPath); err != nil {
		log.Fatalf("Failed to save compressed logs: %v", err)
	}
	fmt.Println("Saved compressed log to", gzPath)
	// Decompress logs
	if err := fileutils.DecompressGzip(gzPath, txtPath); err != nil {
		log.Fatalf("Failed to decompress logs: %v", err)
	}
	fmt.Println("Uncompressed log to", txtPath)
}

// See entire project at https://github.com/mongodb/atlas-architecture-go-sdk
package main
import (
	"context"
	"encoding/json"
	"fmt"
	"log"
	"atlas-sdk-examples/internal/auth"
	"atlas-sdk-examples/internal/config"
	"atlas-sdk-examples/internal/metrics"
	"github.com/joho/godotenv"
	"go.mongodb.org/atlas-sdk/v20250219001/admin"
)
func main() {
	envFile := ".env.production"
	if err := godotenv.Load(envFile); err != nil {
		log.Printf("Warning: could not load %s file: %v", envFile, err)
	}
	secrets, cfg, err := config.LoadAllFromEnv()
	if err != nil {
		log.Fatalf("Failed to load configuration %v", err)
	}
	ctx := context.Background()
	client, err := auth.NewClient(ctx, cfg, secrets)
	if err != nil {
		log.Fatalf("Failed to initialize authentication client: %v", err)
	}
	// Fetch process metrics with the provided parameters
	p := &admin.GetHostMeasurementsApiParams{
		GroupId:   cfg.ProjectID,
		ProcessId: cfg.ProcessID,
		M: &[]string{
			"OPCOUNTER_INSERT", "OPCOUNTER_QUERY", "OPCOUNTER_UPDATE", "TICKETS_AVAILABLE_READS",
			"TICKETS_AVAILABLE_WRITE", "CONNECTIONS", "QUERY_TARGETING_SCANNED_OBJECTS_PER_RETURNED",
			"QUERY_TARGETING_SCANNED_PER_RETURNED", "SYSTEM_CPU_GUEST", "SYSTEM_CPU_IOWAIT",
			"SYSTEM_CPU_IRQ", "SYSTEM_CPU_KERNEL", "SYSTEM_CPU_NICE", "SYSTEM_CPU_SOFTIRQ",
			"SYSTEM_CPU_STEAL", "SYSTEM_CPU_USER",
		},
		Granularity: admin.PtrString("PT1H"),
		Period:      admin.PtrString("P7D"),
	}
	view, err := metrics.FetchProcessMetrics(ctx, client.MonitoringAndLogsApi, p)
	if err != nil {
		log.Fatalf("Failed to fetch process metrics: %v", err)
	}
	// Output metrics
	out, err := json.MarshalIndent(view, "", "  ")
	if err != nil {
		log.Fatalf("Failed to format metrics data: %v", err)
	}
	fmt.Println(string(out))
}

// See entire project at https://github.com/mongodb/atlas-architecture-go-sdk
package main
import (
	"context"
	"fmt"
	"log"
	"atlas-sdk-examples/internal/auth"
	"atlas-sdk-examples/internal/config"
	"atlas-sdk-examples/internal/fileutils"
	"atlas-sdk-examples/internal/logs"
	"github.com/joho/godotenv"
	"go.mongodb.org/atlas-sdk/v20250219001/admin"
)
func main() {
	envFile := ".env.production"
	if err := godotenv.Load(envFile); err != nil {
		log.Printf("Warning: could not load %s file: %v", envFile, err)
	}
	secrets, cfg, err := config.LoadAllFromEnv()
	if err != nil {
		log.Fatalf("Failed to load configuration %v", err)
	}
	ctx := context.Background()
	client, err := auth.NewClient(ctx, cfg, secrets)
	if err != nil {
		log.Fatalf("Failed to initialize authentication client: %v", err)
	}
	// Fetch logs with the provided parameters
	p := &admin.GetHostLogsApiParams{
		GroupId:  cfg.ProjectID,
		HostName: cfg.HostName,
		LogName:  "mongodb",
	}
	fmt.Printf("Request parameters: GroupID=%s, HostName=%s, LogName=%s\n",
		cfg.ProjectID, cfg.HostName, p.LogName)
	rc, err := logs.FetchHostLogs(ctx, client.MonitoringAndLogsApi, p)
	if err != nil {
		log.Fatalf("Failed to fetch logs: %v", err)
	}
	defer fileutils.SafeClose(rc)
	// Prepare output paths
	// If the ATLAS_DOWNLOADS_DIR env variable is set, it will be used as the base directory for output files
	outDir := "logs"
	prefix := fmt.Sprintf("%s_%s", p.HostName, p.LogName)
	gzPath, err := fileutils.GenerateOutputPath(outDir, prefix, "gz")
	if err != nil {
		log.Fatalf("Failed to generate GZ output path: %v", err)
	}
	txtPath, err := fileutils.GenerateOutputPath(outDir, prefix, "txt")
	if err != nil {
		log.Fatalf("Failed to generate TXT output path: %v", err)
	}
	// Save compressed logs
	if err := fileutils.WriteToFile(rc, gzPath); err != nil {
		log.Fatalf("Failed to save compressed logs: %v", err)
	}
	fmt.Println("Saved compressed log to", gzPath)
	// Decompress logs
	if err := fileutils.DecompressGzip(gzPath, txtPath); err != nil {
		log.Fatalf("Failed to decompress logs: %v", err)
	}
	fmt.Println("Uncompressed log to", txtPath)
}