Skip to content

Commit 0a7754f

Browse files
craig[bot]aa-joshi
andcommitted
Merge #151382
151382: cli(tsdump): update tsdump summary log request of Datadog r=aa-joshi a=aa-joshi Previously, TestTSDumpUploadE2E test was failing on `s390x` architecture. It seems like the nested JSON string of Message is not behaving unexpected. It was throwing an error `expected comma after object value`. To address this, this patch updates the Message with the string and rest of the information is passed into the AdditionalProperties of datadogV2.HTTPLogItem. Epic: None Fixes: #150792 Release note: None Co-authored-by: Akshay Joshi <[email protected]>
2 parents 2de4944 + 74bd3a2 commit 0a7754f

File tree

2 files changed

+9
-17
lines changed

2 files changed

+9
-17
lines changed

pkg/cli/testdata/tsdump_upload_e2e

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,6 @@ cr.store.rocksdb.block.cache.usage,2021-01-01T00:00:00Z,2,75.2
88
----
99
{"series":[{"interval":10,"metric":"crdb.tsdump.admission.admitted.elastic-cpu","points":[{"timestamp":1748248320,"value":1}],"tags":["node_id:1","cluster_type:SELF_HOSTED","cluster_label:\"test-cluster\"","cluster_id:test-cluster-id","zendesk_ticket:zd-test","org_name:test-org","user_name:test-user","upload_id:\"test-cluster\"-20241114000000","upload_timestamp:2024-11-14 00:00:00","upload_year:2024","upload_month:11","upload_day:14"],"type":0},{"interval":10,"metric":"crdb.tsdump.sql.query.count","points":[{"timestamp":1609459200,"value":100.5}],"tags":["node_id:1","cluster_type:SELF_HOSTED","cluster_label:\"test-cluster\"","cluster_id:test-cluster-id","zendesk_ticket:zd-test","org_name:test-org","user_name:test-user","upload_id:\"test-cluster\"-20241114000000","upload_timestamp:2024-11-14 00:00:00","upload_year:2024","upload_month:11","upload_day:14"],"type":0},{"interval":10,"metric":"crdb.tsdump.sql.query.count","points":[{"timestamp":1609459210,"value":102.3}],"tags":["node_id:1","cluster_type:SELF_HOSTED","cluster_label:\"test-cluster\"","cluster_id:test-cluster-id","zendesk_ticket:zd-test","org_name:test-org","user_name:test-user","upload_id:\"test-cluster\"-20241114000000","upload_timestamp:2024-11-14 00:00:00","upload_year:2024","upload_month:11","upload_day:14"],"type":0},{"interval":10,"metric":"crdb.tsdump.rocksdb.block.cache.usage","points":[{"timestamp":1609459200,"value":75.2}],"tags":["store:2","cluster_type:SELF_HOSTED","cluster_label:\"test-cluster\"","cluster_id:test-cluster-id","zendesk_ticket:zd-test","org_name:test-org","user_name:test-user","upload_id:\"test-cluster\"-20241114000000","upload_timestamp:2024-11-14 00:00:00","upload_year:2024","upload_month:11","upload_day:14"],"type":0}]}
1010

11-
[{"ddsource":"tsdump_upload","ddtags":"cluster_type:SELF_HOSTED,cluster_label:\"test-cluster\",cluster_id:test-cluster-id,zendesk_ticket:zd-test,org_name:test-org,user_name:test-user,upload_id:\"test-cluster\"-20241114000000,upload_timestamp:2024-11-14 00:00:00,upload_year:2024,upload_month:11,upload_day:14,series_uploaded:4","hostname":"hostname","message":"{\"message\":\"tsdump upload completed: uploaded 4 series overall\",\"series_uploaded\":4,\"estimated_cost\":0.000186986301369863,\"duration\":0,\"dry_run\":false,\"success\":true}","service":"tsdump_upload"}]
11+
[{"ddsource":"tsdump_upload","ddtags":"cluster_type:SELF_HOSTED,cluster_label:\"test-cluster\",cluster_id:test-cluster-id,zendesk_ticket:zd-test,org_name:test-org,user_name:test-user,upload_id:\"test-cluster\"-20241114000000,upload_timestamp:2024-11-14 00:00:00,upload_year:2024,upload_month:11,upload_day:14,series_uploaded:4","dry_run":"false","duration":"0","estimated_cost":"0.000186986301369863","hostname":"hostname","message":"tsdump upload completed: uploaded 4 series overall","series_uploaded":"4","service":"tsdump_upload","success":"true"}]
1212
----
1313
----

pkg/cli/tsdump_upload.go

Lines changed: 8 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -574,28 +574,20 @@ func (d *datadogWriter) upload(fileName string) error {
574574

575575
api := datadogV2.NewLogsApi(d.apiClient)
576576
hostName := getHostname()
577-
msgJson, _ := json.Marshal(struct {
578-
Message string `json:"message"`
579-
SeriesUploaded int `json:"series_uploaded"`
580-
EstimatedCost float64 `json:"estimated_cost"`
581-
Duration int `json:"duration"`
582-
DryRun bool `json:"dry_run"`
583-
Success bool `json:"success"`
584-
}{
585-
Message: fmt.Sprintf("tsdump upload completed: uploaded %d series overall", seriesUploaded),
586-
SeriesUploaded: seriesUploaded,
587-
Duration: int(getCurrentTime().Sub(d.uploadTime).Nanoseconds()),
588-
DryRun: debugTimeSeriesDumpOpts.dryRun,
589-
EstimatedCost: estimatedCost,
590-
Success: success,
591-
})
592577
_, _, err = api.SubmitLog(d.datadogContext, []datadogV2.HTTPLogItem{
593578
{
594579
Ddsource: datadog.PtrString("tsdump_upload"),
595580
Ddtags: datadog.PtrString(strings.Join(eventTags, ",")),
596-
Message: string(msgJson),
581+
Message: fmt.Sprintf("tsdump upload completed: uploaded %d series overall", seriesUploaded),
597582
Service: datadog.PtrString("tsdump_upload"),
598583
Hostname: datadog.PtrString(hostName),
584+
AdditionalProperties: map[string]string{
585+
"series_uploaded": strconv.Itoa(seriesUploaded),
586+
"estimated_cost": fmt.Sprintf("%g", estimatedCost),
587+
"duration": strconv.Itoa(int(getCurrentTime().Sub(d.uploadTime).Nanoseconds())),
588+
"dry_run": strconv.FormatBool(debugTimeSeriesDumpOpts.dryRun),
589+
"success": strconv.FormatBool(success),
590+
},
599591
},
600592
}, datadogV2.SubmitLogOptionalParameters{
601593
ContentEncoding: datadogV2.CONTENTENCODING_GZIP.Ptr(),

0 commit comments

Comments
 (0)