From 857e22bc0b6c0aa3e54729a70037371dc1c04327 Mon Sep 17 00:00:00 2001
From: itaiad200 <itaiad200@gmail.com>
Date: Fri, 26 Jul 2024 11:47:45 +0300
Subject: [PATCH] Add DynamoDB log for scans (#8007)

* Add DynamoDB log for scans

* Update pkg/kv/dynamodb/store.go

Co-authored-by: guy-har <guy.hardonag@treeverse.io>

---------

Co-authored-by: guy-har <guy.hardonag@treeverse.io>
---
 pkg/kv/dynamodb/store.go | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/pkg/kv/dynamodb/store.go b/pkg/kv/dynamodb/store.go
index d9f4f420625..ebbc58a7611 100644
--- a/pkg/kv/dynamodb/store.go
+++ b/pkg/kv/dynamodb/store.go
@@ -522,7 +522,13 @@ func (e *EntriesIterator) runQuery(limit int) {
 	}
 
 	queryInput.Limit = aws.Int32(int32(limit))
-
+	e.store.logger.
+		WithField("partition_key", e.partitionKey).
+		WithField("limit", limit).
+		WithField("exclusive_start_key", e.exclusiveStartKey).
+		WithField("start_key", e.startKey).
+		WithContext(e.scanCtx).
+		Trace("Performing DynamoDB query")
 	queryResult, err := e.store.svc.Query(e.scanCtx, queryInput)
 	const operation = "Query"
 	if err != nil {