如何使用C#实现AWS Lambda预流量/后流量钩子？

我在寻找C#实现AWS Lambda预流量和后流量钩子的示例时，没找到合适的参考，自行摸索完成了可运行的实现，代码如下：

using Amazon.CodeDeploy.Model;
using System.Threading.Tasks;
using Amazon.Lambda.Core;
using System;

namespace xxxxx.LambdaFunctions
{
    [LambdaSerializer(typeof(Amazon.Lambda.Serialization.Json.JsonSerializer))]
    public async Task FunctionHandler(PutLifecycleEventHookExecutionStatusRequest status, ILambdaContext context)
    {
        ArgumentNullException.ThrowIfNull(status);

        LambdaLogger.Log("Processing lifecycle pre-traffic hook.");

        Amazon.CodeDeploy.LifecycleEventStatus? eventStatus = Amazon.CodeDeploy.LifecycleEventStatus.Failed;

        try
        {
            // 在这里添加你的预/后流量钩子测试逻辑
            // 例如：检查新部署服务的健康状态、验证配置有效性等

            eventStatus = Amazon.CodeDeploy.LifecycleEventStatus.Succeeded;
        }
        catch (InvalidStatusCodeException exc)
        {
            eventStatus = Amazon.CodeDeploy.LifecycleEventStatus.Failed;
            LambdaLogger.Log($"PreTrafficHook failed with status code {exc.StatusCode}.");
        }
        catch (Exception exc)
        {
            eventStatus = Amazon.CodeDeploy.LifecycleEventStatus.Failed;
            LambdaLogger.Log($"Error: {exc.Message}");
        }
        finally
        {
            using var codedeploy = new Amazon.CodeDeploy.AmazonCodeDeployClient();

            var request = new PutLifecycleEventHookExecutionStatusRequest()
            {
                DeploymentId = status.DeploymentId,
                LifecycleEventHookExecutionId = status.LifecycleEventHookExecutionId,
                Status = eventStatus,
            };

            await codedeploy.PutLifecycleEventHookExecutionStatusAsync(request).ConfigureAwait(false);
        }
    }
}

关键说明 #

• 该Handler可同时适配**预流量（PreTraffic）和后流量（PostTraffic）**钩子，只需在CodeDeploy部署组的生命周期钩子配置中绑定对应的Lambda函数即可
• 核心逻辑需写在try块内：预流量钩子可用于在流量切换前验证新版本服务的可用性；后流量钩子可用于流量切换后做健康检查或清理工作
• 必须确保通过PutLifecycleEventHookExecutionStatusAsync向CodeDeploy返回明确的成功/失败状态，否则部署流程会一直卡在钩子阶段
• 日志通过LambdaLogger输出，可在AWS CloudWatch的Lambda日志组中查看执行详情

内容的提问来源于stack exchange，提问作者Brian Rice