amazon-web-services - .NET Core API Gateway (AWS) 如何设置依赖注入(inject) (DI) 以使用 MemCached .NET Core 包、基于 DI 的记录器等

Question

我有一个基于 .NET Core API 网关的项目。我想引入依赖注入(inject)(di)，因为我需要引入的很多包都是基于这种模式的，所以需要使用IServiceCollection等等。

我在网上找到的将 DI 引入 AWS Lambda 的示例仅关注标准 Lambda 项目，其中入口点是 Handler 函数。我不确定如何用我的 API Gateway 项目复制它，因为它使用不同的结构。我有一个无参数构造函数

Public Functions()
{}

以及许多实例

        public async Task<APIGatewayProxyResponse> MyProxyResponse(APIGatewayProxyRequest request, ILambdaContext context)
{
}

我不清楚如何将 DI 引入到这个项目中。例如，采用 .NET Core MemCached 包，详细信息请参见此处 https://github.com/cnblogs/EnyimMemcachedCore

我可以设置以下内容:

public class Functions
{
    public IConfiguration Configuration { get; private set; }

    private void ConfigureServices(IServiceCollection serviceCollection)
    {
        serviceCollection.AddEnyimMemcached();
        serviceCollection.AddEnyimMemcached(options => options.AddServer(Environment.GetEnvironmentVariable("CACHE_URL"), 
            Convert.ToInt32(Environment.GetEnvironmentVariable("CACHE_PORT"))));
        // TODO: Register services with DI system
    }

    private readonly AmazonSimpleSystemsManagementClient _systemsManagementClient;
    private readonly JSchema _jSchema;
    private readonly loyaltyContext _loyaltyContext;

    private readonly IMemcachedClient _memcachedClientv2;

但是 _memcachedClientv2 从未被分配，因此它的值将为 null。我不确定如何从上面的内容到达每个 APIGatewayProxyRequest 方法中工作的 _memcachedClientv2。

Answer 1

Naadem Taj 已经为您指明了正确的方向，但这里有一个示例可供澄清。

您需要在 Startup.cs 中设置服务，然后您就可以访问您创建的其他服务中的服务。

举个例子:

public class Startup
{
    public IConfiguration Configuration { get; private set; }

    public Startup(IConfiguration configuration)
    {
        Configuration = configuration;
    }

    private void ConfigureServices(IServiceCollection serviceCollection)
    {
        serviceCollection.AddEnyimMemcached(options => 
            options.AddServer(Environment.GetEnvironmentVariable("CACHE_URL"), 
            Convert.ToInt32(Environment.GetEnvironmentVariable("CACHE_PORT"))));
        
        serviceCollection.AddScoped<IFunctions, Functions>();

        // TODO: Register services with DI system
    }
}

在你的函数中

public interface IFunctions
{
    async Task DoStuff();
}

public class Functions : IFunctions
{
    private readonly AmazonSimpleSystemsManagementClient _systemsManagementClient;
    private readonly JSchema _jSchema;
    private readonly loyaltyContext _loyaltyContext;
    private readonly IMemcachedClient _memcachedClientv2;

    public Functions(loyaltyContext context, AmazonSimpleSystemsManagementClient amazonClient, JSchema jschema, IMemcachedClient memcachedClient)
    {
        _loyaltyContext = context;
        _systemsManagementClient= amazonClient;
        _jSchema = jschema;
        _memcachedClientv2 = memcachedClient;
    }

    public async Task DoStuff()
    {
       // Do stuff here
    }
}