如何在Azure函数中混合自定义参数绑定和依赖注入？

Question

我有一个Azure Functions应用程序，它使用在[WebJobsStartup]中初始化的自定义参数绑定-如何将这些绑定迁移到新的[FunctionsStartup]方式？

在[WebJobsStartup]中，通过调用生成器注册绑定。带有.AddBindingRule的AddExtension

现在，新的Azure SDK说要使用[FunctionsStartup]——我该如何连接（或替换）。在这里添加BindingRule？

FunctionsStartup实现如下所示:-

[assembly: FunctionsStartup(typeof(EventSourcingOnAzureFunctions.Common.Startup))]
namespace EventSourcingOnAzureFunctions.Common
{
    public class Startup
        : FunctionsStartup
    {

        public override void Configure(IFunctionsHostBuilder builder)
        {

            builder.AddAppSettingsToConfiguration();

            // Initialise any common services
            CQRSAzureBindings.InitializeServices(builder.Services);

            builder.Services.AddWebJobs(ConfigureWebJobs  );

        }

        public void ConfigureWebJobs(JobHostOptions hostOptions)
        {

        }
}

它用来注册绑定规则的方式如下:-

        /// <summary>
        /// Initailise any common dependency injection configuration settings
        /// </summary>
        /// <param name="context"></param>
        public static void InitializeInjectionConfiguration(ExtensionConfigContext context)
        {


            // Set up the dependency injection stuff for the custom bindings 
            // 1: EventStream
            context
                .AddBindingRule<EventStreamAttribute>()
                .BindToInput<EventStream>(BuildEventStreamFromAttribute)
                ;
         }

如果我运行函数app，绑定规则代码不会被调用，结果函数索引失败，例如

Microsoft.Azure.WebJobs.Host： Error indexing method 'DepositMoney'.Microsoft.Azure.WebJobs.Host：无法绑定参数'bankAccountEvents'以键入EventStream。确保绑定支持参数 Type。如果使用的是绑定扩展（例如 Azure 存储、ServiceBus、计时器等），请确保已在启动代码（例如生成器）中调用了扩展的注册方法。AddAzureStorage（）， builder.AddServiceBus（）， builder.AddTimers（） 等）。

Answer 1

您可以让[WebJobStartup]实例在Startup.cs中调用builder.AddExtension

在我的情况下，我需要使用 NuGet 包中的扩展

using Microsoft.Azure.WebJobs.Extensions.Kafka;

但是我经历了和你一样的情况，但是最后，我成功了:)

[assembly: 
FunctionsStartup(typeof(EventSourcingOnAzureFunctions.Common.Startup))]
namespace EventSourcingOnAzureFunctions.Common
{
    public class Startup
    : FunctionsStartup
    {

        public override void Configure(IFunctionsHostBuilder builder)
        {
            var serviceProvider = builders.Services.BuildServiceProvider();
            var env = serviceProvider.GetRequiredService<IHostEnvironment>();
            var appDirectory = serviceProvider.GetRequiredService<IOptions<ExecutionContextOptions>>().Value.AppDirectory;

            // IWebJobsBuilders instance
            var wbBuilder = builder.Services.AddWebJobs(x => { return; });
            wbBuilder.AddKafka();

            // And now you can use AddExtension
            // wbBuilder.AddExtension

        }
 }

Answer 2

要做到这一点，您将有两个单独的启动类。一个继承自FunctionsStartup，另一个实现IWebJobStartup接口。WebJobStartup首先运行，然后是FunctionsStartup。

以下是我测试它的方式。

WebJobsStartup类

namespace CustomBinding
{
    public class WebJobsStartup : IWebJobsStartup
    {
        void IWebJobsStartup.Configure(IWebJobsBuilder builder)
        {
            Debug.WriteLine("WebJobsStartup.Configure");
        }
    }
}

汇编信息类

using Microsoft.Azure.WebJobs.Hosting;

[assembly: WebJobsStartup(typeof(CustomBinding.WebJobsStartup))]

创业班

[assembly: FunctionsStartup(typeof(CustomBinding.Startup))]

namespace CustomBinding
{

    public class Startup : FunctionsStartup
    {
        public override void Configure(IFunctionsHostBuilder builder)
        {
            Debug.WriteLine("FunctionsStartup.Configure");
        }        
    }   
}