gsadmin/AutopilotMonitor
1
0
Fork 0
mirror of https://github.com/okieselbach/AutopilotMonitor.git synced 2026-10-24 04:32:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

more efficient delete via batching

Browse Source
This commit is contained in:
Oliver Kieselbach
2026-02-08 12:55:16 +01:00
parent 66d69f8074
commit e1e747d65b
1 changed files with 33 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Backend/AutopilotMonitor.Functions/Services/TableStorageService.cs
+33 -3
View File
@@ -595,10 +595,20 @@ namespace AutopilotMonitor.Functions.Services
var events = tableClient.QueryAsync<TableEntity>(filter);
int deletedCount = 0;
var batch = new List<TableTransactionAction>();
await foreach (var eventEntity in events)
{
await tableClient.DeleteEntityAsync(eventEntity.PartitionKey, eventEntity.RowKey);
batch.Add(new TableTransactionAction(TableTransactionActionType.Delete, eventEntity));
deletedCount++;
if (batch.Count >= 100)
{
await tableClient.SubmitTransactionAsync(batch);
batch.Clear();
}
}
if (batch.Count > 0)
{
await tableClient.SubmitTransactionAsync(batch);
}
_logger.LogInformation($"Deleted {deletedCount} events for session {sessionId}");
@@ -1252,10 +1262,20 @@ namespace AutopilotMonitor.Functions.Services
filter: $"PartitionKey eq '{tenantId}' and SessionId eq '{sessionId}'");
int deletedCount = 0;
var batch = new List<TableTransactionAction>();
await foreach (var entity in query)
{
await tableClient.DeleteEntityAsync(entity.PartitionKey, entity.RowKey);
batch.Add(new TableTransactionAction(TableTransactionActionType.Delete, entity));
deletedCount++;
if (batch.Count >= 100)
{
await tableClient.SubmitTransactionAsync(batch);
batch.Clear();
}
}
if (batch.Count > 0)
{
await tableClient.SubmitTransactionAsync(batch);
}
return deletedCount;
@@ -1282,10 +1302,20 @@ namespace AutopilotMonitor.Functions.Services
var query = tableClient.QueryAsync<TableEntity>(filter: $"PartitionKey eq '{partitionKey}'");
int deletedCount = 0;
var batch = new List<TableTransactionAction>();
await foreach (var entity in query)
{
await tableClient.DeleteEntityAsync(entity.PartitionKey, entity.RowKey);
batch.Add(new TableTransactionAction(TableTransactionActionType.Delete, entity));
deletedCount++;
if (batch.Count >= 100)
{
await tableClient.SubmitTransactionAsync(batch);
batch.Clear();
}
}
if (batch.Count > 0)
{
await tableClient.SubmitTransactionAsync(batch);
}
return deletedCount;