feat: add alias as a de-duplication ID

PeerDB-io · Mar 1, 2024 · a32f990 · a32f990
1 parent c103b08
commit a32f990
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/flow/shared/telemetry/sns_message_sender.go b/flow/shared/telemetry/sns_message_sender.go
@@ -2,7 +2,9 @@ package telemetry
 
 import (
 	"context"
+	"fmt"
 	"strings"
+	"time"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
 	"github.com/aws/aws-sdk-go-v2/config"
@@ -47,6 +49,10 @@ func (s *SNSMessageSenderImpl) SendMessage(ctx context.Context, subject string,
 				DataType:    aws.String("String"),
 				StringValue: aws.String(attributes.Type),
 			},
+			"alias": { // This will act as a de-duplication ID
+				DataType:    aws.String("String"),
+				StringValue: aws.String(fmt.Sprintf("[%s] - [%s] - [Window: %s]", attributes.DeploymentUID, subject, time.Now().Truncate(30*time.Minute))),
+			},
 		},
 		Subject:  aws.String(subject[:100]),
 		TopicArn: aws.String(s.topic),