Asp.Net Core で定時実行Job を実装するなら Cronos nugetパッケージがお勧め

Asp.Net Core で、定時実行するJob、バックグラウンドタスクを実装するなら、Cronos nugetパッケージを使うと、実装が断然楽になるのでお勧め。

Cronos nugetパッケージ

githubに実装サンプルがあり、そのソースコードをコピーペーストすれば実装も直ぐ終わる。

Schedule Cron Jobs using HostedService in ASP.NET Core に詳しい実装説明がある。

How should I inject a DbContext instance into an IHostedService? の方法で、DB処理も簡単に実装できる。

組み込み手順

１．Cronos nugetパッケージをインストールする。

２．サンプルソースをダウンロードする。

３．サンプルソースのServiceWorkerCronJobDemoプロジェクトから主なソースを、本ソースへコピーする。

３-1．Startup.cs
　ConfigureServices()にAddCronJob()コピーし、実行時間だけ修正する。


            services.AddCronJob<MyCronJob1>(c =>
            {
                c.TimeZoneInfo = TimeZoneInfo.Local;
                c.CronExpression = @"*/5 * * * *";
            });

services.AddCronJob<MyCronJob1>(c =>

{

c.TimeZoneInfo = TimeZoneInfo.Local;

c.CronExpression = @"*/5 * * * *";

});

３-2．CronJobService.cs
　CronJobService.cs をまるごとコピーし、namespaceだけ合わせる。

３-3．MyCronJob1.cs
　MyCronJob1 .cs をまるごとコピーし、namespaceを合わせ、DoWork()内に個別の実行処理を追加する。
　DB処理が必要な場合、このように修正する。


using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;

namespace ServiceWorkerCronJobDemo.Services
{
    public class MyCronJob1 : CronJobService
    {
        private readonly IServiceScopeFactory scopeFactory;
        private readonly ILogger<MyCronJob1> _logger;

        public MyCronJob1(IScheduleConfig<MyCronJob1> config, ILogger<MyCronJob1> logger, IServiceScopeFactory scopeFactory)
            : base(config.CronExpression, config.TimeZoneInfo)
        {
            _logger = logger;
        }

        public override Task StartAsync(CancellationToken cancellationToken)
        {
            _logger.LogInformation("CronJob 1 starts.");
            return base.StartAsync(cancellationToken);
        }

        public override Task DoWork(CancellationToken cancellationToken)
        {
            _logger.LogInformation($"{DateTime.Now:hh:mm:ss} CronJob 1 is working.");

            using (var scope = scopeFactory.CreateScope())
            {
                var dbContext = scope.ServiceProvider.GetRequiredService<ApplicationDbContext>();

                // DB処理 //
            }

            return Task.CompletedTask;
        }

        public override Task StopAsync(CancellationToken cancellationToken)
        {
            _logger.LogInformation("CronJob 1 is stopping.");
            return base.StopAsync(cancellationToken);
        }
    }
}

using System;

using System.Threading;

using System.Threading.Tasks;

using Microsoft.Extensions.DependencyInjection;

using Microsoft.Extensions.Logging;

namespace ServiceWorkerCronJobDemo.Services

{

public class MyCronJob1 : CronJobService

{

private readonly IServiceScopeFactory scopeFactory;

private readonly ILogger<MyCronJob1> _logger;

public MyCronJob1(IScheduleConfig<MyCronJob1> config, ILogger<MyCronJob1> logger, IServiceScopeFactory scopeFactory)

: base(config.CronExpression, config.TimeZoneInfo)

{

_logger = logger;

}

public override Task StartAsync(CancellationToken cancellationToken)

{

_logger.LogInformation("CronJob 1 starts.");

return base.StartAsync(cancellationToken);

}

public override Task DoWork(CancellationToken cancellationToken)

{

_logger.LogInformation($"{DateTime.Now:hh:mm:ss} CronJob 1 is working.");

using (var scope = scopeFactory.CreateScope())

{

var dbContext = scope.ServiceProvider.GetRequiredService<ApplicationDbContext>();

// DB処理 //

}

return Task.CompletedTask;

}

public override Task StopAsync(CancellationToken cancellationToken)

{

_logger.LogInformation("CronJob 1 is stopping.");

return base.StopAsync(cancellationToken);

}