Azure 函数 V3 依赖关系注入生存期问题

Question

我正在使用Azure函数v3和DI。我有一个服务，我在启动时设置了一个短暂的生命周期。cs（使用：builder.Services.AddTransient

我希望对于每个队列消息，我将获得我的“coreApiService”的一个单独实例，但当多个消息同时放入队列时，我似乎正在共享一个实例。

我希望为每个调用或“运行”获得一个单独的实例是不正确的吗？我遇到的问题是“_coreApiClient”似乎在Run方法的多个调用之间共享，因此当我在其中设置属性（如“客户ID”或“API密钥”等）时，我对一条消息有效，并且应该在该消息的处理中保持不变，因为它开始处理下一条消息。

是我做错了还是我没有正确理解生命？

这是我的启动代码:

public class Startup: FunctionsStartup
    {
        public override void Configure(IFunctionsHostBuilder builder)
        {
            builder.Services.AddLogging();
            
            var loggingService = new HttpLoggingService(Environment.GetEnvironmentVariable("LoggingURL"), 0, "ABC.Integrations");
            builder.Services.AddTransient<ILoggingService>(s => loggingService);

            int CoreApiTimeout = 60;  //Environment.GetEnvironmentVariable("CoreApiTimeout")
            var coreApiService = new CoreApiClient(Environment.GetEnvironmentVariable("CoreApiKey"),string.Empty, CoreApiTimeout,Environment.GetEnvironmentVariable("CoreApiBaseUrl"));
            builder.Services.AddTransient<ICoreApiClient>(s => coreApiService);
           
        }
    }

和我的Azure Function类：

public class TaskRouter
    {
        private readonly ICoreApiClient _coreApiClient;
        private readonly ILoggingService _upgLogger;
        private readonly ILogger<TaskRouter> _log;        

        public TaskRouter(ICoreApiClient coreApiClient, ILoggingService upgLogger, ILogger<TaskRouter> log)
        {
            _coreApiClient = coreApiClient;
            _upgLogger = upgLogger;
            _log = log;
            
        }

        [FunctionName("RouteTask")]
        [ExponentialBackoffRetry(5, "00:00:04", "00:03:00")]
        public async Task Run([QueueTrigger("task-scheduler", Connection = "")]
            string queueItem)
        {

            
                //Call Appropriate Function to start task
                var taskMsg = JsonConvert.DeserializeObject<TaskMessage>(queueItem);
                                
                _coreApiClient.SetId(taskMsg.TaskNumber);
                
                //DO SOME WORK HERE
                
                Console.Log(_coreApiClient.GetId);  //Will be different b/c this was set by the next message
        }
   }




Answer 1

尽管客户端在容器中注册为瞬态，但它实际上是一个单例，因为在 Startup 中创建的实例是每次调用注入 ICoreApiClient 时将返回的唯一实例。

将实例创建移动到factory委托中，使其成为实际的临时注册，以便每次必须从服务提供商解析iCorapClient时都会初始化新实例。

//...

builder.Services.AddTransient<ICoreApiClient>(s => 
    new CoreApiClient(Environment.GetEnvironmentVariable("CoreApiKey"), string.Empty, CoreApiTimeout, Environment.GetEnvironmentVariable("CoreApiBaseUrl"))
);

//...