Hangfire.Mongo
1.10.9
dotnet add package Hangfire.Mongo --version 1.10.9
NuGet\Install-Package Hangfire.Mongo -Version 1.10.9
<PackageReference Include="Hangfire.Mongo" Version="1.10.9" />
paket add Hangfire.Mongo --version 1.10.9
#r "nuget: Hangfire.Mongo, 1.10.9"
// Install Hangfire.Mongo as a Cake Addin #addin nuget:?package=Hangfire.Mongo&version=1.10.9 // Install Hangfire.Mongo as a Cake Tool #tool nuget:?package=Hangfire.Mongo&version=1.10.9
Hangfire.Mongo
MongoDB support for Hangfire library. By using this library you can store all jobs information in MongoDB.
Installation
To install Hangfire MongoDB Storage, run the following command in the Nuget Package Manager Console:
PM> Install-Package Hangfire.Mongo
Usage ASP.NET Core
public void ConfigureServices(IServiceCollection services)
{
var mongoUrlBuilder = new MongoUrlBuilder("mongodb://localhost/jobs");
var mongoClient = new MongoClient(mongoUrlBuilder.ToMongoUrl());
// Add Hangfire services. Hangfire.AspNetCore nuget required
services.AddHangfire(configuration => configuration
.SetDataCompatibilityLevel(CompatibilityLevel.Version_180)
.UseSimpleAssemblyNameTypeSerializer()
.UseRecommendedSerializerSettings()
.UseMongoStorage(mongoClient, mongoUrlBuilder.DatabaseName, new MongoStorageOptions
{
MigrationOptions = new MongoMigrationOptions
{
MigrationStrategy = new MigrateMongoMigrationStrategy(),
BackupStrategy = new CollectionMongoBackupStrategy()
},
Prefix = "hangfire.mongo",
CheckConnection = true
})
);
// Add the processing server as IHostedService
services.AddHangfireServer(serverOptions =>
{
serverOptions.ServerName = "Hangfire.Mongo server 1";
});
// Add framework services.
}
Usage ASP.NET
var options = new MongoStorageOptions
{
MigrationOptions = new MongoMigrationOptions
{
MigrationStrategy = new DropMongoMigrationStrategy(),
BackupStrategy = new NoneMongoBackupStrategy()
}
};
GlobalConfiguration.Configuration.UseMongoStorage("mongodb://localhost/jobs", options);
app.UseHangfireServer();
app.UseHangfireDashboard();
Usage Console
var options = new MongoStorageOptions
{
MigrationOptions = new MongoMigrationOptions
{
MigrationStrategy = new DropMongoMigrationStrategy(),
BackupStrategy = new NoneMongoBackupStrategy()
}
};
var mongoStorage = new MongoStorage(
MongoClientSettings.FromConnectionString("mongodb://localhost"),
"jobs", // database name
options);
using(new BackgroundJobServer(mongoStorage))
{
...
}
Custom collections prefix
To use custom prefix for collections names specify it on Hangfire setup:
public void Configuration(IAppBuilder app)
{
GlobalConfiguration.Configuration.UseMongoStorage("mongodb://localhost/ApplicationDatabase",
new MongoStorageOptions { Prefix = "custom" } );
app.UseHangfireServer();
app.UseHangfireDashboard();
}
Configuration Overrides
CheckQueuedJobsStrategy
(default:Watch
)Watch
uses change streams to watch for enqueued jobs. Will still poll using 'QueuePollInterval'.Poll
will poll periodically using 'QueuePollInterval', recommended for large installments.TailNotificationsCollection
uses a capped, tailable collection to notify nodes of enqueued jobs. Will still poll using 'QueuePollInterval'. Works with single node MongoDB instances.
Naming Convention
Hangfire.Mongo will ignore any naming conventions configured by your application. E.g. if your application use camel casing like this:
var camelCaseConventionPack = new ConventionPack { new CamelCaseElementNameConvention() };
ConventionRegistry.Register("CamelCase", camelCaseConventionPack, type => true);
it will be ignored by Hangfire.Mongo and Pascal Case will be used instead. Of cause only for Hangfire specific collections.
Migration
We sometimes introduce breaking changes in the schema. For this reason we have introduced migration. Three migration strategies exists.
Throw
This is the default migration strategy. It will throw an InvalidOperationException never letting you get up and running if there is a schema version mismatch. So it forces you to decide what migration strategy is best for you and at the same time keeps your data safe.
Drop
This will simply just drop your existing Hangfire.Mongo database and update the schema version. No fuzz and ready to start from scratch. It is the perfect strategy if you e.g. enque all your jobs at startup.
Migrate
This will migrate your database from one schema version to the next until the required schema version is reached. Chances are that not all data can be migrated, why some loss of data might occur. Please use with caution and thougoughly test before deploying to production. We are not responsible for data loss.
NOTE: Only forward migration is supported. If you need to revert to a previous schema version, you need to manually drop or restore the previous database.
public void Configuration(IAppBuilder app)
{
var migrationOptions = new MongoMigrationOptions
{
MigrationStrategy = new MigrateMongoMigrationStrategy(),
BackupStrategy = new CollectionMongoBackupStrategy()
};
var storageOptions = new MongoStorageOptions
{
// ...
MigrationOptions = migrationOptions
};
GlobalConfiguration.Configuration.UseMongoStorage("<connection string with database name>", storageOptions);
app.UseHangfireServer();
app.UseHangfireDashboard();
}
NOTE: By default the parameter InvisibilityTimeout
of the MongoStorageOptions
is configured with the value null
, making the job to stay in status 'processing' in case of an error in the application. To solve this issue, set the value to 30 minutes like in the SqlServerStorageOptions.
public void Configuration(IAppBuilder app)
{
var migrationOptions = new MongoMigrationOptions
{
MigrationStrategy = new MigrateMongoMigrationStrategy(),
BackupStrategy = new CollectionMongoBackupStrategy()
};
var storageOptions = new MongoStorageOptions
{
// ...
MigrationOptions = migrationOptions,
InvisibilityTimeout = TimeSpan.FromMinutes(30)
};
GlobalConfiguration.Configuration.UseMongoStorage("<connection string with database name>", storageOptions);
app.UseHangfireServer();
app.UseHangfireDashboard();
}
Migration Backup
By default no backup is made before attempting to migrate. You can backup Hangfire collections by "cloning" each collection to the same database. Alternatively you can just write your own, by inheriting MongoBackupStrategy and use that implementation.
NOTE: This software is made by humans in our sparetime - we do our best but will not be held responsible for any data loss.
Contributors
- Sergey Zwezdin (@sergeyzwezdin)
- Martin Løbger (@marloe)
- Jonas Gottschau (@gottscj)
License
Hangfire.Mongo is released under the MIT License.
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net5.0 was computed. net5.0-windows was computed. net6.0 was computed. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
.NET Core | netcoreapp2.0 was computed. netcoreapp2.1 was computed. netcoreapp2.2 was computed. netcoreapp3.0 was computed. netcoreapp3.1 was computed. |
.NET Standard | netstandard2.0 is compatible. netstandard2.1 was computed. |
.NET Framework | net461 was computed. net462 was computed. net463 was computed. net47 was computed. net471 was computed. net472 was computed. net48 was computed. net481 was computed. |
MonoAndroid | monoandroid was computed. |
MonoMac | monomac was computed. |
MonoTouch | monotouch was computed. |
Tizen | tizen40 was computed. tizen60 was computed. |
Xamarin.iOS | xamarinios was computed. |
Xamarin.Mac | xamarinmac was computed. |
Xamarin.TVOS | xamarintvos was computed. |
Xamarin.WatchOS | xamarinwatchos was computed. |
-
.NETStandard 2.0
- Hangfire.Core (>= 1.8.14)
- MongoDB.Driver (>= 2.29.0)
NuGet packages (20)
Showing the top 5 NuGet packages that depend on Hangfire.Mongo:
Package | Downloads |
---|---|
DiegoRangel.DotNet.Framework.CQRS.Infra.CrossCutting.Hangfire
A common library for implementing CQRS based CrossCutting Hangfire layer. |
|
EaCloud.Hangfire
EaCloud Hangfire 后台任务组件,封装基于 Hangfire 后台任务的服务端实现。 |
|
Jcex.Infra.Hangfire
该库提供了一种方便的 Hangfire 定时任务管理方式,使用 MongoDB 来存储任务信息,并内置 Web 界面来监控和操作任务。全面可视化的界面提供了对任务状态和进度的监控。 |
|
MicroCloud.Hangfire
MicroCloud Hangfire 后台任务组件,封装基于 Hangfire 后台任务的服务端实现。 |
|
nguyendk.DotnetExtensions.NET
Package Description |
GitHub repositories (1)
Showing the top 1 popular GitHub repositories that depend on Hangfire.Mongo:
Repository | Stars |
---|---|
gnsilence/HangfireHttpJob
hangfire的拓展程序,在原作者基础上增加了一些功能,调用api的方式来执行定时任务
|
Version | Downloads | Last updated |
---|---|---|
1.10.9 | 1,216 | 10/3/2024 |
1.10.8 | 50,518 | 8/7/2024 |
1.10.7 | 80,389 | 6/17/2024 |
1.10.6 | 93,363 | 4/24/2024 |
1.10.5 | 25,999 | 4/9/2024 |
1.10.4 | 87,972 | 2/26/2024 |
1.10.3 | 36,872 | 2/11/2024 |
1.10.2 | 2,419 | 2/8/2024 |
1.10.1 | 1,255 | 2/7/2024 |
1.10.0 | 977 | 2/7/2024 |
1.9.16 | 55,874 | 1/4/2024 |
1.9.15 | 65,953 | 11/28/2023 |
1.9.14 | 27,087 | 11/12/2023 |
1.9.13 | 678 | 11/10/2023 |
1.9.12 | 35,080 | 10/28/2023 |
1.9.11 | 32,531 | 10/14/2023 |
1.9.10 | 47,869 | 9/21/2023 |
1.9.9 | 29,939 | 9/11/2023 |
1.9.8 | 47,039 | 8/14/2023 |
1.9.7 | 133,646 | 7/18/2023 |
1.9.6 | 47,106 | 6/18/2023 |
1.9.5 | 140,386 | 5/18/2023 |
1.9.4 | 3,654 | 5/15/2023 |
1.9.3 | 148,065 | 3/31/2023 |
1.9.2 | 176,947 | 2/2/2023 |
1.9.1 | 212,597 | 12/19/2022 |
1.9.0 | 28,560 | 12/10/2022 |
1.7.3 | 436,024 | 8/24/2022 |
1.7.2 | 137,072 | 6/13/2022 |
1.7.1 | 47,473 | 6/8/2022 |
1.7.0 | 250,176 | 3/19/2022 |
0.7.28 | 196,705 | 1/2/2022 |
0.7.27 | 137,379 | 11/3/2021 |
0.7.25 | 84,096 | 9/20/2021 |
0.7.24 | 111,870 | 8/8/2021 |
0.7.22 | 273,886 | 5/2/2021 |
0.7.20 | 95,854 | 3/25/2021 |
0.7.19 | 77,612 | 2/10/2021 |
0.7.17 | 153,218 | 11/20/2020 |
0.7.12 | 153,266 | 8/12/2020 |
0.7.11 | 196,860 | 6/7/2020 |
0.6.7 | 195,477 | 3/19/2020 |
0.6.6 | 427,383 | 12/11/2019 |
0.6.5 | 86,545 | 10/21/2019 |
0.6.4 | 18,264 | 9/26/2019 |
0.6.3 | 28,031 | 8/14/2019 |
0.6.2 | 18,743 | 7/28/2019 |
0.6.1 | 39,062 | 6/16/2019 |
0.6.0 | 43,086 | 4/23/2019 |
0.5.15 | 147,534 | 1/3/2019 |
0.5.14 | 1,995 | 1/1/2019 |
0.5.13 | 13,649 | 12/13/2018 |
0.5.12 | 46,723 | 10/28/2018 |
0.5.11 | 85,243 | 9/5/2018 |
0.5.10 | 40,005 | 5/27/2018 |
0.5.9 | 55,547 | 2/20/2018 |
0.5.8 | 2,240 | 2/20/2018 |
0.5.7 | 86,571 | 11/20/2017 |
0.5.6 | 1,819 | 11/20/2017 |
0.5.5 | 12,681 | 10/14/2017 |
0.5.4 | 10,591 | 9/22/2017 |
0.5.3 | 3,033 | 9/21/2017 |
0.5.2 | 30,152 | 9/1/2017 |
0.5.1 | 2,391 | 8/30/2017 |
0.5.0 | 3,809 | 8/17/2017 |
0.4.1 | 14,466 | 6/22/2017 |
0.4.0 | 5,260 | 6/19/2017 |
0.3.2 | 59,513 | 12/10/2016 |
0.3.1 | 2,163 | 11/30/2016 |
0.3.0 | 2,169 | 11/29/2016 |
0.2.8 | 8,399 | 9/26/2016 |
0.2.6 | 217,387 | 5/29/2016 |
0.2.5 | 5,102 | 3/5/2016 |
0.2.4 | 2,508 | 2/15/2016 |
0.2.3 | 2,828 | 12/6/2015 |
0.2.2 | 5,825 | 7/12/2015 |
0.2.1 | 3,118 | 12/13/2014 |
0.2.0 | 2,402 | 12/7/2014 |
1.10.9
- Update to MongoDB 2.29.0