fix traffic by only requesting most recent for last insert ts (#1677)

gobitfly · Nov 16, 2022 · 213338e · 213338e
1 parent 7c6070c
commit 213338e
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/db/bigtable.go b/db/bigtable.go
@@ -112,7 +112,12 @@ func (bigtable *Bigtable) SaveMachineMetric(process string, userID uint64, machi
 }
 
 func (bigtable *Bigtable) getLastMachineMetricInsertTs(ctx context.Context, rowKey string) (gcp_bigtable.Timestamp, error) {
-	row, err := bigtable.tableMachineMetrics.ReadRow(ctx, rowKey)
+	filter := gcp_bigtable.ChainFilters(
+		gcp_bigtable.FamilyFilter(MACHINE_METRICS_COLUMN_FAMILY),
+		gcp_bigtable.LatestNFilter(1),
+	)
+
+	row, err := bigtable.tableMachineMetrics.ReadRow(ctx, rowKey, gcp_bigtable.RowFilter(filter))
 	if err != nil {
 		return 0, err
 	}