Here is the IHostedService:

public class Worker : BackgroundService {  private readonly ILogger<Worker> _logger;  private readonly IHttpClientFactory _httpClientFactory; private readonly IConfiguration _configuration;  public Worker(ILogger<Worker> logger, IHttpClientFactory httpClientFactory, IConfiguration configuration) { _logger = logger; _httpClientFactory = httpClientFactory; _configuration = configuration; }  protected override async Task ExecuteAsync(CancellationToken stoppingToken) { //Timer with 3 mins var timer = new PeriodicTimer(TimeSpan.FromMinutes(3)); while (await timer.WaitForNextTickAsync(stoppingToken))  {   await GetData();   _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now); }  }  private async Task MakeRequestsToRemoteService(string productCode, long id)  {  if (id <= 0) throw new ArgumentOutOfRangeException(nameof(id)); try {  var httpClient = _httpClientFactory.CreateClient("RazerClient"); //Token  httpClient.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded"));   var tokenContent = new FormUrlEncodedContent(new[] { new KeyValuePair<string, string>("username", "Test"),   new KeyValuePair<string, string>("password", "123456")  });    using var tokenResponse = await httpClient.PostAsync(_configuration["Token:Production"], tokenContent); if ((int)tokenResponse.StatusCode == 200) { var token = await tokenResponse.Content.ReadAsStringAsync(); //Call Razer Multi Requests httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer",  token); httpClient.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded")); #region Calculate quantity var num = amount;  var firstNum = 50;  var secondNum = 50; if (num < 100) { firstNum = (num + 1) / 2;  secondNum = num - firstNum;  } #endregion var quantities = new List<int> { firstNum, secondNum};  var cts = new CancellationTokenSource(); ParallelOptions parallelOptions = new() {  MaxDegreeOfParallelism = 2,  CancellationToken = cts.Token  };  try {  await Parallel.ForEachAsync(quantities, parallelOptions, async (quantity, ct) => { var content = new FormUrlEncodedContent(new[] { new KeyValuePair<string, string>("productCode", productCode),  new KeyValuePair<string, string>("quantity", quantity.ToString()),   new KeyValuePair<string, string>("clientTrxRef", bulkId.ToString())   });   using var response = await httpClient.PostAsync(_configuration["Razer:Production"], content, ct); if ((int)response.StatusCode == 200) { var coupon = await response.Content.ReadFromJsonAsync<Root>(cancellationToken: ct); _logger.LogInformation("REFERENCE ID: {referenceId}", coupon.ReferenceId); await UpdateData(id); } else { _logger.LogError("Purchase ServiceError: {statusCode}", (int)response.StatusCode); } }); } catch (OperationCanceledException ex) { _logger.LogError("Operation canceled: {Message}", ex.Message); }   } else { _logger.LogError("Token ServiceError: {statusCode}",  (int)tokenResponse.StatusCode); }  } catch (Exception e) { _logger.LogError("Error: {Error} ", e.Message); throw;  }  } private async Task GetData() { var sw = Stopwatch.StartNew(); var connString = _configuration["ConnectionStrings:Default"]; await using var sqlConnection = new SqlConnection(connString); sqlConnection.Open();  await using var command = new SqlCommand { Connection = sqlConnection }; const string sql = @"Select TOP 1 Id, BulkId, Amount, ProductCode from BulkPurchases where status = 0"; command.CommandText = sql; try { await using var reader = await command.ExecuteReaderAsync();   while (reader.Read()) { _logger.LogInformation( "Order {Id}, {BulkId}, {Amount}, {ProductCode}", reader.GetInt32(0), reader.GetInt32(1), reader.GetInt32(2), reader.GetString(3)); await MakeRequestsToRemoteService(reader.GetString(3).Trim(), reader.GetInt32(0)); } }  catch (SqlException exception) { _logger.LogError("Error: {Error} ", exception.Message);   throw; // Throw exception if this exception is unexpected   }  sw.Stop(); _logger.LogInformation($"******** ELAPSED TIME: {sw.Elapsed.TotalSeconds} seconds ********"); } private async Task UpdateData(long id) {  var connString = _configuration["ConnectionStrings:Default"];  await using var sqlConnection = new SqlConnection(connString); sqlConnection.Open(); await using var command = new SqlCommand { Connection = sqlConnection }; const string sql = @"Update BulkPurchases set status = 1 where Id = @id"; command.CommandText = sql; command.Parameters.Add(new SqlParameter("id", id)); try { await command.ExecuteNonQueryAsync(); } catch (SqlException exception) { _logger.LogError("Error: {Error} ", exception.Message); throw; // Throw exception if this exception is unexpected } } } 

Here is the Worker:

 using System.Data; using System.Data.SqlClient; using System.Diagnostics; using System.Net; using System.Net.Http; using System.Net.Http.Headers; using System.Net.Http.Json; using System.Text; using PurchaseRazerCodesMultipleRequestService.Modal; using TrendyolGameCodeService.Modal; namespace PurchaseRazerCodesMultipleRequestService {  public class Worker : BackgroundService { private readonly ILogger<Worker> _logger; private readonly IHttpClientFactory _httpClientFactory; private readonly IConfiguration _configuration;  public Worker(ILogger<Worker> logger, IHttpClientFactory httpClientFactory, IConfiguration configuration) { _logger = logger; _httpClientFactory = httpClientFactory; _configuration = configuration;  } protected override async Task ExecuteAsync(CancellationToken stoppingToken) { ///Random Timer var timer = new PeriodicTimer(TimeSpan.FromMinutes(new Random().Next(1, 2))); _logger.LogInformation("Timer: {timer}", DateTimeOffset.Now);   while (await timer.WaitForNextTickAsync(stoppingToken)) { await GetData(); _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now); } } private async Task MakeRequestsToRemoteService(string productCode, long id, int amount, int bulkId) {  if (id <= 0) throw new ArgumentOutOfRangeException(nameof(id)); try { var httpClient = _httpClientFactory.CreateClient("RazerClient"); //Token httpClient.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded")); var tokenContent = new FormUrlEncodedContent(new[] { new KeyValuePair<string, string>("username", "Test"), new KeyValuePair<string, string>("password", "+REyN-#V5!_DgUn+y%hVj7VmyhN^+?%y+Qxkc-bLZR6$uqsYV") }); using var tokenResponse = await httpClient.PostAsync(_configuration["Token:Production"], tokenContent); if ((int)tokenResponse.StatusCode == 200) { var token = await tokenResponse.Content.ReadAsStringAsync();  //Call Razer Multi Requests  httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer",   token);  httpClient.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded"));  #region Calculate quantity  var num = amount;  var firstNum = 50; var secondNum = 50;    if (num < 100) { firstNum = (num + 1) / 2; secondNum = num - firstNum; } #endregion var quantities = new List<int> { firstNum, secondNum};  var cts = new CancellationTokenSource(); ParallelOptions parallelOptions = new() { MaxDegreeOfParallelism = 2, CancellationToken = cts.Token   }; try { await Parallel.ForEachAsync(quantities, parallelOptions, async (quantity, ct) => { var content = new FormUrlEncodedContent(new[] { new KeyValuePair<string, string>("productCode", productCode), new KeyValuePair<string, string>("quantity", quantity.ToString()), new KeyValuePair<string, string>("clientTrxRef", bulkId.ToString())   }); using var response = await httpClient.PostAsync(_configuration["Razer:Production"], content, ct); if ((int)response.StatusCode == 200) { var coupon = await response.Content.ReadFromJsonAsync<Root>(cancellationToken: ct); _logger.LogInformation("REFERENCE ID: {referenceId}", coupon.ReferenceId); await UpdateData(id);   }   else   {   _logger.LogError("Purchase ServiceError: {statusCode}",   (int)response.StatusCode); } }); } catch (OperationCanceledException ex) {   _logger.LogError("Operation canceled: {Message}", ex.Message); } } else { _logger.LogError("Token ServiceError: {statusCode}", (int)tokenResponse.StatusCode); } } catch (Exception e) { _logger.LogError("Error: {Error} ", e.Message);  } } private async Task GetData()    {    var sw = Stopwatch.StartNew();  var connString = _configuration["ConnectionStrings:Default"];    await using var sqlConnection = new SqlConnection(connString);  sqlConnection.Open();  await using var command = new SqlCommand { Connection = sqlConnection }; const string sql = @"Select TOP 1 Id, BulkPurchaseRequestId, Amount, ProductCode from BulkPurchases where status = 0 ORDER BY NEWID()"; command.CommandText = sql;  try { await using var reader = await command.ExecuteReaderAsync(); while (reader.Read()) { _logger.LogInformation(   "Order {Id}, {BulkId}, {Amount}, {ProductCode}",   reader.GetInt32(0), reader.GetInt32(1), reader.GetInt32(2), reader.GetString(3));   await MakeRequestsToRemoteService(reader.GetString(3).Trim(), reader.GetInt32(0), reader.GetInt32(2),reader.GetInt32(1)); } } catch (SqlException exception)   {   _logger.LogError("Error: {Error} ", exception.Message); }  sw.Stop(); _logger.LogInformation($"******** ELAPSED TIME: {sw.Elapsed.TotalSeconds} seconds ********"); } private async Task UpdateData(long id)   {  var connString = _configuration["ConnectionStrings:Default"];    await using var sqlConnection = new SqlConnection(connString);  sqlConnection.Open();   await using var command = new SqlCommand { Connection = sqlConnection }; const string sql = @"Update BulkPurchases set status = 1 where Id = @id"; command.CommandText = sql;   command.Parameters.Add(new SqlParameter("id", id)); try   {   await command.ExecuteNonQueryAsync();   }   catch (SqlException exception)   {   _logger.LogError("Error: {Error} ", exception.Message);     } } } } 

Online game codes are used for purchasing items in online games

public class Worker : BackgroundService { private readonly ILogger<Worker> _logger; private readonly IHttpClientFactory _httpClientFactory; private readonly IConfiguration _configuration; public Worker(ILogger<Worker> logger, IHttpClientFactory httpClientFactory, IConfiguration configuration) { _logger = logger; _httpClientFactory = httpClientFactory; _configuration = configuration; } protected override async Task ExecuteAsync(CancellationToken stoppingToken) { //Timer with 3 mins var timer = new PeriodicTimer(TimeSpan.FromMinutes(3)); while (await timer.WaitForNextTickAsync(stoppingToken)) { await GetData(); _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now); } } private async Task MakeRequestsToRemoteService(string productCode, long id) { if (id <= 0) throw new ArgumentOutOfRangeException(nameof(id)); try { var httpClient = _httpClientFactory.CreateClient("RazerClient"); //Token httpClient.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded")); var tokenContent = new FormUrlEncodedContent(new[] { new KeyValuePair<string, string>("username", "Test"), new KeyValuePair<string, string>("password", "123456") }); using var tokenResponse = await httpClient.PostAsync(_configuration["Token:Production"], tokenContent); if ((int)tokenResponse.StatusCode == 200) { var token = await tokenResponse.Content.ReadAsStringAsync(); //Call Razer Multi Requests httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token); httpClient.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded")); var quantities = new List<int> { 100, 100, 100, 100, 100 }; var cts = new CancellationTokenSource(); ParallelOptions parallelOptions = new() { MaxDegreeOfParallelism = 2, CancellationToken = cts.Token }; try { await Parallel.ForEachAsync(quantities, parallelOptions, async (quantity, ct) => { var content = new FormUrlEncodedContent(new[] { new KeyValuePair<string, string>("productCode", productCode), new KeyValuePair<string, string>("quantity", quantity.ToString()) }); using var response = await httpClient.PostAsync(_configuration["Razer:Production"], content, ct); if ((int)response.StatusCode == 200) { var coupon = await response.Content.ReadFromJsonAsync<Root>(cancellationToken: ct); _logger.LogInformation("REFERENCE ID: {referenceId}", coupon.ReferenceId); await UpdateData(id); } else { _logger.LogError("Purchase ServiceError: {statusCode}", (int)response.StatusCode); } }); } catch (OperationCanceledException ex) { _logger.LogError("Operation canceled: {Message}", ex.Message); } } else { _logger.LogError("Token ServiceError: {statusCode}", (int)tokenResponse.StatusCode); } } catch (Exception e) { _logger.LogError("Error: {Error} ", e.Message); throw; } } private async Task GetData() { var sw = Stopwatch.StartNew(); var connString = _configuration["ConnectionStrings:Default"]; await using var sqlConnection = new SqlConnection(connString); sqlConnection.Open(); await using var command = new SqlCommand { Connection = sqlConnection }; const string sql = @"Select TOP 1 Id, BulkId, Amount, ProductCode from BulkPurchases where status = 0"; command.CommandText = sql; try { await using var reader = await command.ExecuteReaderAsync(); while (reader.Read()) { _logger.LogInformation( "Order {Id}, {BulkId}, {Amount}, {ProductCode}", reader.GetInt32(0), reader.GetInt32(1), reader.GetInt32(2), reader.GetString(3)); await MakeRequestsToRemoteService(reader.GetString(3).Trim(), reader.GetInt32(0)); } } catch (SqlException exception) { _logger.LogError("Error: {Error} ", exception.Message); throw; // Throw exception if this exception is unexpected } sw.Stop(); _logger.LogInformation($"******** ELAPSED TIME: {sw.Elapsed.TotalSeconds} seconds ********"); } private async Task UpdateData(long id) { var connString = _configuration["ConnectionStrings:Default"]; await using var sqlConnection = new SqlConnection(connString); sqlConnection.Open(); await using var command = new SqlCommand { Connection = sqlConnection }; const string sql = @"Update BulkPurchases set status = 1 where Id = @id"; command.CommandText = sql; command.Parameters.Add(new SqlParameter("id", id)); try { await command.ExecuteNonQueryAsync(); } catch (SqlException exception) { _logger.LogError("Error: {Error} ", exception.Message); throw; // Throw exception if this exception is unexpected } } } 

public class Worker : BackgroundService { private readonly ILogger<Worker> _logger; private readonly IHttpClientFactory _httpClientFactory; private readonly IConfiguration _configuration; public Worker(ILogger<Worker> logger, IHttpClientFactory httpClientFactory, IConfiguration configuration) { _logger = logger; _httpClientFactory = httpClientFactory; _configuration = configuration; } protected override async Task ExecuteAsync(CancellationToken stoppingToken) { //Timer with 3 mins var timer = new PeriodicTimer(TimeSpan.FromMinutes(3)); while (await timer.WaitForNextTickAsync(stoppingToken)) { await GetData(); _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now); } } private async Task MakeRequestsToRemoteService(string productCode, long id) { if (id <= 0) throw new ArgumentOutOfRangeException(nameof(id)); try { var httpClient = _httpClientFactory.CreateClient("RazerClient"); //Token httpClient.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded")); var tokenContent = new FormUrlEncodedContent(new[] { new KeyValuePair<string, string>("username", "Test"), new KeyValuePair<string, string>("password", "123456") }); using var tokenResponse = await httpClient.PostAsync(_configuration["Token:Production"], tokenContent); if ((int)tokenResponse.StatusCode == 200) { var token = await tokenResponse.Content.ReadAsStringAsync(); //Call Razer Multi Requests httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token); httpClient.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded")); #region Calculate quantity var num = amount;   var firstNum = 50;  var secondNum = 50; if (num < 100) {  firstNum = (num + 1) / 2; secondNum = num - firstNum; } #endregion var quantities = new List<int> { firstNum, secondNum}; var cts = new CancellationTokenSource(); ParallelOptions parallelOptions = new() { MaxDegreeOfParallelism = 2, CancellationToken = cts.Token }; try { await Parallel.ForEachAsync(quantities, parallelOptions, async (quantity, ct) => { var content = new FormUrlEncodedContent(new[] { new KeyValuePair<string, string>("productCode", productCode), new KeyValuePair<string, string>("quantity", quantity.ToString()),  new KeyValuePair<string, string>("clientTrxRef", bulkId.ToString()) }); using var response =  await httpClient.PostAsync(_configuration["Razer:Production"], content, ct); if ((int)response.StatusCode == 200) { var coupon = await response.Content.ReadFromJsonAsync<Root>(cancellationToken: ct); _logger.LogInformation("REFERENCE ID: {referenceId}", coupon.ReferenceId); await UpdateData(id); } else { _logger.LogError("Purchase ServiceError: {statusCode}", (int)response.StatusCode); } }); } catch (OperationCanceledException ex) { _logger.LogError("Operation canceled: {Message}", ex.Message); } } else { _logger.LogError("Token ServiceError: {statusCode}", (int)tokenResponse.StatusCode); } } catch (Exception e) { _logger.LogError("Error: {Error} ", e.Message); throw; } } private async Task GetData() { var sw = Stopwatch.StartNew(); var connString = _configuration["ConnectionStrings:Default"]; await using var sqlConnection = new SqlConnection(connString); sqlConnection.Open(); await using var command = new SqlCommand { Connection = sqlConnection }; const string sql = @"Select TOP 1 Id, BulkId, Amount, ProductCode from BulkPurchases where status = 0"; command.CommandText = sql; try { await using var reader = await command.ExecuteReaderAsync(); while (reader.Read()) { _logger.LogInformation( "Order {Id}, {BulkId}, {Amount}, {ProductCode}", reader.GetInt32(0), reader.GetInt32(1), reader.GetInt32(2), reader.GetString(3)); await MakeRequestsToRemoteService(reader.GetString(3).Trim(), reader.GetInt32(0)); } } catch (SqlException exception) { _logger.LogError("Error: {Error} ", exception.Message); throw; // Throw exception if this exception is unexpected } sw.Stop(); _logger.LogInformation($"******** ELAPSED TIME: {sw.Elapsed.TotalSeconds} seconds ********"); } private async Task UpdateData(long id) { var connString = _configuration["ConnectionStrings:Default"]; await using var sqlConnection = new SqlConnection(connString); sqlConnection.Open(); await using var command = new SqlCommand { Connection = sqlConnection }; const string sql = @"Update BulkPurchases set status = 1 where Id = @id"; command.CommandText = sql; command.Parameters.Add(new SqlParameter("id", id)); try { await command.ExecuteNonQueryAsync(); } catch (SqlException exception) { _logger.LogError("Error: {Error} ", exception.Message); throw; // Throw exception if this exception is unexpected } } } 

Edit

I have written a ASP.NET Core Web API that retrieves game codes from another external API. The process works like this: the game code and the number of codes to be retrieved are sent in the request. However, there is a restriction in the external API I am retrieving the game codes from, which is that only 10 game codes can be retrieved in one request. This process is currently being done in various chain stores' cash registers. Only one game code purchase transaction is made from the cash register.

However, there can be customers who want to bulk retrieve thousands of game codes online. To achieve this, I added a new method to the API to enable multiple purchases by looping. The requests are sent to the external API in small pieces, with 10 being the requested amount of game codes. This process works without any problems because each successful request and response is recorded in the database. This process is carried out through the ASP.NET Core interface and has a limitation: if the user inputs the amount of game codes requested through the interface, it takes a long time to retrieve thousands of game codes as the maximum is 100 (to avoid time-out issues, etc.).

To improve this situation, I created a worker service that operates in the background. The user inputs the total request through the web interface, which is converted into 100s and recorded in the database. The worker service retrieves these requests one by one randomly, then sends the requests to the API I created and then to the external API. The new process in the worker service is as follows: when 100 game code requests are made, the maximum parallelism is 2 and they are sent in Parallel.ForEachAsync, divided into 50/50. The requests are processed in the manner described in 10s, as previously mentioned. My concern here is if 100 game codes are successfully sent and retrieved, I update the related record in the database. However, if an error occurs somewhere in the process of processing the external API in 10s, my API will return a 500 error. I'm not exactly sure whether the Parallel.ForEachAsync will continue processing the other requests or if the operation will be cancelled. I was unable to test this scenario. What logic would be appropriate to construct here? Especially for the update scenario. Is there a way to mock the service in order to get errors once in a while so that I can test the logic?