From 213338ed3e6b85f45fcab08eea8b5972e9f2b506 Mon Sep 17 00:00:00 2001 From: Manuel Caspari Date: Wed, 16 Nov 2022 14:56:28 +0100 Subject: [PATCH] fix traffic by only requesting most recent for last insert ts (#1677) --- db/bigtable.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/db/bigtable.go b/db/bigtable.go index c911108a63..c40b5d456e 100644 --- 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 }