Rag.NET.Ingestion.AzureServiceBus
1.0.0
dotnet add package Rag.NET.Ingestion.AzureServiceBus --version 1.0.0
NuGet\Install-Package Rag.NET.Ingestion.AzureServiceBus -Version 1.0.0
<PackageReference Include="Rag.NET.Ingestion.AzureServiceBus" Version="1.0.0" />
<PackageVersion Include="Rag.NET.Ingestion.AzureServiceBus" Version="1.0.0" />
<PackageReference Include="Rag.NET.Ingestion.AzureServiceBus" />
paket add Rag.NET.Ingestion.AzureServiceBus --version 1.0.0
#r "nuget: Rag.NET.Ingestion.AzureServiceBus, 1.0.0"
#:package Rag.NET.Ingestion.AzureServiceBus@1.0.0
#addin nuget:?package=Rag.NET.Ingestion.AzureServiceBus&version=1.0.0
#tool nuget:?package=Rag.NET.Ingestion.AzureServiceBus&version=1.0.0
Rag.NET.Ingestion.AzureServiceBus
Azure Service Bus ingestion trigger for Rag.NET: consumes messages from a queue or subscription, ingests each one end-to-end, and settles it on the outcome — complete on success, abandon for retry, dead-letter when poisonous — so a crash mid-ingest means redelivery, not loss.
Install
dotnet add package Rag.NET.Ingestion.AzureServiceBus
Install alongside the core pipeline package (dotnet add package Rag.NET), which supplies
the AddRagNet(...) builder the trigger registers into.
Setup
Inside your AddRagNet(...) builder callback:
using Rag.NET.Ingestion.AzureServiceBus;
rag.UseServiceBusIngestion(
connectionString: Environment.GetEnvironmentVariable("SERVICEBUS_CONNECTION_STRING")!,
queueName: "rag-ingest");
An overload takes a fully qualified namespace + TokenCredential for managed identity.
Example
Concurrency and lock renewal are the operational knobs:
using Rag.NET.Ingestion.AzureServiceBus;
rag.UseServiceBusIngestion(
connectionString: Environment.GetEnvironmentVariable("SERVICEBUS_CONNECTION_STRING")!,
queueName: "rag-ingest",
configure: o =>
{
o.MaxConcurrentCalls = 4; // default 1
o.MaxAutoLockRenewalDuration = TimeSpan.FromMinutes(10); // default 5, for slow documents
});
The trigger deliberately bypasses the in-memory job queue: it settles each broker message only after the ingest outcome is known, keeping Service Bus's at-least-once guarantee.
Full guide
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net10.0 is compatible. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
-
net10.0
- Azure.Messaging.ServiceBus (>= 7.20.2)
- Microsoft.Extensions.DependencyInjection.Abstractions (>= 10.0.12)
- Microsoft.Extensions.Hosting.Abstractions (>= 10.0.12)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.12)
- Rag.NET.Abstractions (>= 1.0.0)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.