Put in same partition due to bulk operations spanning different parti…

…tions
cammurray · May 10, 2024 · 1219e59 · 1219e59
1 parent 0e5d219
commit 1219e59
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/Sync.cs b/Sync.cs
@@ -321,10 +321,13 @@ private static async Task GetTenantSimulationUsers(GraphServiceClient GraphClien
         var pageIterator = Microsoft.Graph.PageIterator<UserSimulationDetails,UserSimulationDetailsCollectionResponse>
             .CreatePageIterator(GraphClient, results, async (userSimDetail) =>
             {
+                // Create an identifier for the SimulationUser_Id
+                string id = $"{SimulationId}-{userSimDetail.SimulationUser?.UserId}";
+
                 // Add the table item
-                tableActionQueue_SimulationUsers.Enqueue(new TableTransactionAction(TableTransactionActionType.UpdateReplace, new TableEntity(SimulationId, userSimDetail.SimulationUser?.UserId)
+                tableActionQueue_SimulationUsers.Enqueue(new TableTransactionAction(TableTransactionActionType.UpdateReplace, new TableEntity("SimulationUsers", id)
                 {
-                    {"SimulationUser_Id", $"{SimulationId}-{userSimDetail.SimulationUser?.UserId}"},
+                    {"SimulationUser_Id", id},
                     {"SimulationUser_UserId", userSimDetail.SimulationUser?.UserId},
                     {"SimulationUser_Email", userSimDetail.SimulationUser?.Email},
                     {"CompromisedDateTime", userSimDetail.CompromisedDateTime},
@@ -347,7 +350,7 @@ private static async Task GetTenantSimulationUsers(GraphServiceClient GraphClien
                 {
                     foreach (var simulationUserEvents in userSimDetail.SimulationEvents)
                     {
-                        tableActionQueue_SimulationUserEvents.Enqueue(new TableTransactionAction(TableTransactionActionType.UpdateReplace, new TableEntity(SimulationId, $"{userSimDetail.SimulationUser?.UserId}_{simulationUserEvents.EventName}_{simulationUserEvents.EventDateTime.Value.ToUnixTimeSeconds()}")
+                        tableActionQueue_SimulationUserEvents.Enqueue(new TableTransactionAction(TableTransactionActionType.UpdateReplace, new TableEntity("SimulationUserEvents", $"{id}_{simulationUserEvents.EventName}_{simulationUserEvents.EventDateTime.Value.ToUnixTimeSeconds()}")
                         {
                             {"SimulationUser_Id", $"{SimulationId}-{userSimDetail.SimulationUser?.UserId}"},
                             {"SimulationUser_UserId", userSimDetail.SimulationUser?.UserId},