如何创建服务总线触发 webjob？

Question

我检查doc 使用下面的代码来配置webjob 以创建服务总线触发功能。

    static void Main()
{
    var builder = new HostBuilder();
    builder.ConfigureWebJobs(b =>
    {
        b.AddAzureStorageCoreServices();
        b.AddServiceBus(sbOptions =>
        {
            sbOptions.MessageHandlerOptions.AutoComplete = true;
            sbOptions.MessageHandlerOptions.MaxConcurrentCalls = 16;
        });
    });
    var host = builder.Build();
    using (host)
    {

        host.Run();
    }
}

但是当我尝试实现它时，AddServiceBus方法不可用，即使添加服务总线触发功能它总是报No job functions found错误。

那么配置错误在哪里，感谢您的帮助。

Answer 1

根据我的经验，当您创建网络作业时，您没有使用正确的包。如果你检查service bus binding doc，你会发现它需要Microsoft.Azure.WebJobs.Extensions.ServiceBus来提供服务总线绑定。

在我的测试下，你需要以下包：

1. Microsoft.Azure.WebJobs(>= 3.0.10)
2. Microsoft.Azure.WebJobs.Extensions
3. Microsoft.Azure.WebJobs.Extensions.ServiceBus
4. Microsoft.Azure.WebJobs.ServiceBus

使用Microsoft.Azure.WebJobs.Extensions.ServiceBus，您将能够使用b.AddServiceBus() 方法和Microsoft.Azure.WebJobs.ServiceBus 创建ServiceBusTrigger 函数。

下面是我的测试代码，试试看。

public static void Main(string[] args)
    {
        var builder = new HostBuilder();
        builder.ConfigureWebJobs(b =>
        {
            b.AddAzureStorageCoreServices();
            b.AddServiceBus();
        });
        builder.ConfigureLogging((context, b) =>
        {
            b.AddConsole();
        });
        var host = builder.Build();
        using (host)
        {
            host.Run();
        }
    }

函数.cs

public static void processservicebus(
    [ServiceBusTrigger("test", Connection = "ServiceBusConnection")]string myQueueItem,
    ILogger log)
    {
        log.LogInformation(myQueueItem);
    }

希望对您有所帮助，如果您还有其他问题，请随时告诉我。