From 191d23e0044c3d9e1769847d5ed76d03042b3838 Mon Sep 17 00:00:00 2001 From: "m.malygina" Date: Thu, 20 Jun 2024 11:03:24 +0300 Subject: [PATCH] add logs to delete Signed-off-by: m.malygina --- internal/s3/client.go | 2 +- scenarios/s3_dar.js | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/internal/s3/client.go b/internal/s3/client.go index 0765807..ac0937c 100644 --- a/internal/s3/client.go +++ b/internal/s3/client.go @@ -108,7 +108,7 @@ func (c *Client) Multipart(bucket, key string, objPartSize, concurrency int, pay func (c *Client) Delete(bucket, key string) DeleteResponse { start := time.Now() - + println("Delete bucket:", bucket, " key:", key) _, err := c.cli.DeleteObject(c.vu.Context(), &s3.DeleteObjectInput{ Bucket: aws.String(bucket), Key: aws.String(key), diff --git a/scenarios/s3_dar.js b/scenarios/s3_dar.js index 15ee09c..e6c2328 100644 --- a/scenarios/s3_dar.js +++ b/scenarios/s3_dar.js @@ -182,6 +182,7 @@ export function obj_read() { if (!obj ) { return; } + log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'READ START'}).info("INFO"); const resp = s3_client.get(obj.s3_bucket, obj.s3_key) if (!resp.success) { log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, status: obj.status, op: `READ`}) @@ -189,7 +190,7 @@ export function obj_read() { } else { obj_registry.setObjectStatus(obj.id, obj.status, 'read'); } - + log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'READ FINISHED'}).info("INFO"); return }