correct write read scenarios in benchmark (added ScenarioTimestamp fi…

…eld)
PragmaticFlow · Sep 17, 2024 · 973556f · 973556f
1 parent 4144f56
commit 973556f
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 6 deletions.
diff --git a/benchmarks/TimescaleBenchmark/Program.cs b/benchmarks/TimescaleBenchmark/Program.cs
@@ -31,7 +31,7 @@ public void Run()
         var readScenario = new ReadScenario().Create(connectionString, DateTime.UtcNow, sessionId: "0");
 
         NBomberRunner
-            .RegisterScenarios(writeScenario)
+            .RegisterScenarios(readScenario)
             .WithTestSuite("reporting")
             .WithTestName("timescale_db_demo")
             .Run();

diff --git a/benchmarks/TimescaleBenchmark/ReadScenario.cs b/benchmarks/TimescaleBenchmark/ReadScenario.cs
@@ -58,6 +58,7 @@ public ScenarioProps Create(string connectionString, DateTime startTime, string
                 .Select(i => new PointDbRecord
                 { 
                     Time = startTime.AddSeconds(-5 * i),
+                    ScenarioTimestamp = TimeSpan.Zero,
                     Step = fakePoint.Step,
                     Scenario = fakePoint.Scenario,
                     

diff --git a/benchmarks/TimescaleBenchmark/TimescaleBenchmark.csproj b/benchmarks/TimescaleBenchmark/TimescaleBenchmark.csproj
@@ -10,8 +10,8 @@
         <PackageReference Include="AutoBogus" Version="2.13.1" />
         <PackageReference Include="NBomber" Version="5.7.0" />
         <PackageReference Include="Dapper" Version="2.1.35" />
-        <PackageReference Include="RepoDb.PostgreSql" Version="1.13.1" />
-        <PackageReference Include="RepoDb.PostgreSql.BulkOperations" Version="1.13.1" />
+        <PackageReference Include="RepoDb.PostgreSql" Version="1.13.2-alpha1" />
+        <PackageReference Include="RepoDb.PostgreSql.BulkOperations" Version="1.13.2-alpha1" />
     </ItemGroup>
 
     <ItemGroup>

diff --git a/benchmarks/TimescaleBenchmark/WriteScenario.cs b/benchmarks/TimescaleBenchmark/WriteScenario.cs
@@ -22,13 +22,18 @@ public ScenarioProps Create(string connectionString)
             {
                 await using var connection = new NpgsqlConnection(connectionString);
             
-                var curTime = DateTime.UtcNow;
+                var curTime = DateTime.UtcNow; 
             
                 fakePoint.Time = curTime;
+                fakePoint.ScenarioTimestamp = TimeSpan.Zero;
                 fakePoint.SessionId = ctx.ScenarioInfo.InstanceNumber.ToString();
                 fakePoint.CurrentOperation = NBomber.Contracts.Stats.OperationType.Bombing;
-
-                await connection.BinaryBulkInsertAsync(SqlQueries.StepStatsTable, Enumerable.Repeat(fakePoint, 5));
+                try
+                {
+                    await connection.BinaryBulkInsertAsync(SqlQueries.StepStatsTable, Enumerable.Repeat(fakePoint, 5));
+                }
+                catch (Exception ex) 
+                { }
                 
                 return Response.Ok();
             });