CZY/MES-ETL
1
0
Fork 0
Code Pull Requests Releases Activity

修复output计数

Browse Source
This commit is contained in:
lindj 2024-01-17 13:37:49 +08:00
parent e0df7ff4e9
commit 08e0444055
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
ConsoleApp2/HostedServices/OutputService.cs
View File

@ -40,7 +40,6 @@ public class OutputService : IOutputService
public async Task ExecuteAsync(CancellationToken cancellationToken) public async Task ExecuteAsync(CancellationToken cancellationToken)
{ {
_logger.LogInformation("***** Mysql output service started *****"); _logger.LogInformation("***** Mysql output service started *****");
var count = 0;
_taskManager.CreateTasks(async () => _taskManager.CreateTasks(async () =>
{ {
var records = new List<DataRecord>(); var records = new List<DataRecord>();
@ -48,12 +47,10 @@ public class OutputService : IOutputService
{ {
if (!_consumerQueue.TryDequeue(out var record)) continue; if (!_consumerQueue.TryDequeue(out var record)) continue;
records.Add(record); records.Add(record);
count++;
//_logger.LogInformation(@"*****OutputCount: {count} *****",count); //_logger.LogInformation(@"*****OutputCount: {count} *****",count);
if (records.Count >= _outputOptions.Value.FlushCount) if (records.Count >= _outputOptions.Value.FlushCount)
{ {
await FlushAsync(records); await FlushAsync(records);
_context.AddOutput(count);
records.Clear(); records.Clear();
} }
if (_context.GetExceptions().Count>0) if (_context.GetExceptions().Count>0)