NLog AsyncTaskTarget在第一次迭代后不批量处理行

Question

我正在尝试为NLog编写一个自定义异步目标，将日志推送到Azure，并遇到意外情况。基本上这样：当我调用的异步任务很慢时（在本例中为1.5s），在第一批之后，所有剩余的日志条目都是单批发送的。

这可以使用TaskDelayMilliseconds的各种值以及各种应用程序延迟进行重现。除了异常/重试之外，我希望每个“TaskDelayMilliseconds”都有一个“写”操作。我怀疑这可能是AsyncTaskTarget中的一个错误，但在提交之前我想要一个社区评论。有什么想法吗？提前致谢。

此代码需要NLog Nuget 4.6.0-rc3。当前版本中不提供要重写的新异步批处理方法。

[Target("AsyncTestTarget")]
public class AsyncTestTarget : AsyncTaskTarget
{
    protected override void InitializeTarget()
    {
        base.InitializeTarget();

        BatchSize = 10000;
        TaskDelayMilliseconds = 3000;
    }


    protected override Task WriteAsyncTask(LogEventInfo logEvent, CancellationToken cancellationToken)
    {
        InternalLogger.Info($"NLog.Extensions.AsyncTestTarget.WriteAsyncTask()");
        return WriteAsyncTask(new List<LogEventInfo> {logEvent}, cancellationToken);
    }

    protected override Task WriteAsyncTask(IList<LogEventInfo> logEvents, CancellationToken cancellationToken)
    {
        InternalLogger.Info($"NLog.Extensions.AsyncTestTarget.WriteAsyncTask(List) : {logEvents.Count}");
        if (!logEvents.Any())
            return Task.CompletedTask;
        // If this line is commented, the rows are batched as expected.  If this line is left as-is, then after the first batch, records are sent one at a time.
        System.Threading.Thread.Sleep(TimeSpan.FromMilliseconds(1500));

        return Task.CompletedTask;
    }
}

示例程序代码：

class Program
{
    static ILogger logger = LogManager.GetCurrentClassLogger();
    static void Main(string[] args)
    {

        for (var i = 0; i < 5000; i++)
        {
            logger.Info(i.ToString());
            System.Threading.Thread.Sleep(TimeSpan.FromMilliseconds(100));
        }

        logger.Info("Done");

        LogManager.Flush(TimeSpan.FromSeconds(15));
    }
}

NLog配置：

<nlog internalLogLevel="Debug" internalLogToConsole="true">
    <extensions>
      <add assembly="ConsoleApp1"/>
    </extensions>

    <targets>
      <target type="console" name="console"/>
      <target type="AsyncTestTarget" name="test" />
    </targets>

    <rules>
      <logger name="*" minlevel="Trace" writeTo="console" />
      <logger name="*" minlevel="Trace" writeTo="test" />
    </rules>
</nlog>

WriteAsyncTask中没有睡眠的屏幕截图：

在Write AsyncTask（大）中睡眠的屏幕截图：qazxsw poi

Answer 1

NLog 4.6.1已经发布，解决了：#3185