Merge pull request #1171 from cocoa-mhlw/feature/save_partition_key_i…

…n_eventlog_api Feature/save partition key in eventlog api
cocoa-mhlw · Oct 17, 2022 · acc6b83 · acc6b83
2 parents adfc824 + 1f6320e
commit acc6b83
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/src/Covid19Radar.Api/DataAccess/CosmosEventLogRepository.cs b/src/Covid19Radar.Api/DataAccess/CosmosEventLogRepository.cs
@@ -26,7 +26,12 @@ ILogger<CosmosEventLogRepository> logger
 
  public async Task UpsertAsync(EventLogModel eventLog)
  {
- ItemResponse<EventLogModel> recordAdded = await _db.EventLog.UpsertItemAsync(eventLog);
+ PartitionKey? pk = null;
+ if(eventLog.PartitionKey is not null)
+ {
+ pk = new PartitionKey(eventLog.PartitionKey);
+ } 
+ ItemResponse<EventLogModel> recordAdded = await _db.EventLog.UpsertItemAsync(eventLog, pk);
  _logger.LogInformation($"{nameof(UpsertAsync)} RequestCharge:{recordAdded.RequestCharge}");
  }
  }

diff --git a/src/Covid19Radar.Api/V1EventLog.cs b/src/Covid19Radar.Api/V1EventLog.cs
@@ -139,6 +139,7 @@ public async Task<IActionResult> RunAsync(
  )
  {
  id = id,
+ PartitionKey = id,
  Created = timestamp,
  };
  await _eventLogRepository.UpsertAsync(eventLogModel);