Amazon.Lambda.RuntimeSupport 1.10.0

Amazon.Lambda.RuntimeSupport

Amazon.Lambda.RuntimeSupport 包是用于 Lambda Runtime API 的 .NET Lambda 运行时接口客户端 (RIC)。Lambda 运行时接口客户端允许您的运行时接收来自 Lambda 服务的请求并向 Lambda 服务发送请求。它可以用于构建作为自定义运行时或容器镜像的 .NET Lambda 函数。从.NET 6 开始，它也是管理运行时中使用的 Lambda 客户端。

容器镜像支持

AWS 提供包含所有必需组件的基础镜像，这些组件打包为容器镜像并在 AWS Lambda 上运行您的函数。从 AWS Lambda .NET 5 基础镜像开始，Amazon.Lambda.RuntimeSupport 用作 Lambda 运行时客户端。该库针对 .NET Standard 2.0，也可以用于支持 .NET Standard 的更早版本的 .NET Core，如 3.1。

在AWS Lambda .NET基本镜像中，该库已预安装在/var/runtime目录中。使用基本镜像的.NET Lambda函数不直接与此包交互。相反，它们传递一个图像命令或一个Dockerfile CMD，其中指定要运行的.NET代码。该参数的格式为<assembly-name>::<full-type-name>::<function-name>。

对于未预安装Amazon.Lambda.RuntimeSupport的自定义基本容器镜像，可以将该库作为类库包含在.NET Lambda函数代码中。要了解如何使用Amazon.Lambda.RuntimeSupport作为类库来构建.NET Lambda函数，请参考本README中的强<强>Using Amazon.Lambda.RuntimeSupport as a class library部分。

下面的Dockerfile展示了如何使用自定义基本镜像构建Lambda函数。在此示例中，基本镜像是Microsoft的.NET 6运行时镜像。此Dockerfile将.NET Lambda函数复制到/var/task目录，然后使用dotnet CLI执行.NET Lambda项目，这将初始化Amazon.Lambda.RuntimeSupport库并开始响应Lambda事件。

FROM mcr.microsoft.com/dotnet/runtime:6.0

WORKDIR /var/task

COPY "bin/Release/net6.0/linux-x64/publish"  .

ENTRYPOINT ["/usr/bin/dotnet", "exec", "/var/task/LambdaContainerCustomBase.dll"]

使用Amazon.Lambda.RuntimeSupport as a class library

Amazon.Lambda.RuntimeSupport可作为类库用于与Lambda运行时API交互。这是通过添加NuGet依赖项Amazon.Lambda.RuntimeSupport和在Lambda .NET项目中添加一个Main函数来初始化Amazon.Lambda.RuntimeSupport库来完成的。下面的例子展示了ToUpperAsync方法的签名。这默认为函数处理程序，当使用Amazon.Lambda.RuntimeSupport.LambdaBootstrap类时。

private static MemoryStream ResponseStream = new MemoryStream();
private static JsonSerializer JsonSerializer = new JsonSerializer();

private static async Task Main(string[] args)
{
    using(var bootstrap = new LambdaBootstrap(ToUpperAsync))
    {
        await bootstrap.RunAsync();
    }
}

private static Task<InvocationResponse> ToUpperAsync(InvocationRequest invocation)
{
    var input = JsonSerializer.Deserialize<string>(invocation.InputStream);

    ResponseStream.SetLength(0);
    JsonSerializer.Serialize(input.ToUpper(), ResponseStream);
    ResponseStream.Position = 0;

    return Task.FromResult(new InvocationResponse(responseStream, false));
}

Amazon.Lambda.RuntimeSupport.HandlerWrapper类允许您使用LambdaBootstrap与现有处理程序。Amazon.Lambda.RuntimeSupport.HandlerWrapper类还为您处理反序列化和序列化。

private static async Task Main(string[] args)
{
    using(var handlerWrapper = HandlerWrapper.GetHandlerWrapper((Func<string, ILambdaContext, string>)ToUpper, new JsonSerializer()))
    using(var bootstrap = new LambdaBootstrap(handlerWrapper))
    {
        await bootstrap.RunAsync();
    }
}

// existing handler doesn't conform to the new Amazon.Lambda.RuntimeSupport default signature
public static string ToUpper(string input, ILambdaContext context)
{
    return input?.ToUpper();
}

Amazon.Lambda.RuntimeSupport.RuntimeApiClient类负责与AWS Lambda运行时接口交互。此类旨在用于高级用例。在大多数情况下，您不会直接使用它。

以下是从Amazon.Lambda.RuntimeSupport.LambdaBootstrap类中的一个摘录，展示了如何使用Amazon.Lambda.RuntimeSupport.RuntimeApiClient。要了解更多信息，请阅读Amazon.Lambda.RuntimeSupport.LambdaBootstrap的完整源代码。

internal async Task InvokeOnceAsync()
{
    using (var invocation = await Client.GetNextInvocationAsync())
    {
        InvocationResponse response = null;
        bool invokeSucceeded = false;

        try
        {
            response = await _handler(invocation);
            invokeSucceeded = true;
        }
        catch (Exception exception)
        {
            await Client.ReportInvocationErrorAsync(invocation.LambdaContext.AwsRequestId, exception);
        }

        if (invokeSucceeded)
        {
            try
            {
                await Client.SendResponseAsync(invocation.LambdaContext.AwsRequestId, response?.OutputStream);
            }
            finally
            {
                if (response != null && response.DisposeOutputStream)
                {
                    response.OutputStream?.Dispose();
                }
            }
        }
    }
}