如何在CodePipeline第三阶段读取CloudFormation输出的ELB DNS名？

看起来你已经搭好了流水线的前两步，接下来要搞定Lambda读取ELB DNS做健康检查的话，我给你梳理一下具体的实现步骤，都是实战中验证过的方案：

一、先给Lambda配置必要的IAM权限 #

Lambda要能读取CloudFormation栈的输出，首先得给它的执行角色加对应的权限。你需要创建或更新Lambda的IAM角色，添加cloudformation:DescribeStacks权限，资源指定你的目标CFN栈的ARN（生产环境建议限定到具体栈，避免过度授权）。

示例IAM策略：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "cloudformation:DescribeStacks",
            "Resource": "arn:aws:cloudformation:us-east-1:123456789012:stack/your-test-stack/*"
        },
        {
            "Effect": "Allow",
            "Action": [
                "logs:CreateLogGroup",
                "logs:CreateLogStream",
                "logs:PutLogEvents"
            ],
            "Resource": "arn:aws:logs:*:*:*"
        }
    ]
}

注：日志权限是Lambda运行的必备项，别漏掉

二、编写Lambda函数实现核心逻辑 #

我以Python为例写个完整的实现，逻辑清晰直白：先拉取CFN栈的输出拿到ELB DNS，再发HTTP请求做健康检查，还加了重试逻辑应对资源启动延迟。

import boto3
import requests
import os
from requests.adapters import HTTPAdapter
from urllib3.util.retry import Retry

# 初始化CloudFormation客户端
cfn_client = boto3.client('cloudformation')
# 从环境变量取栈名，避免硬编码更灵活
STACK_NAME = os.environ.get('STACK_NAME')
# 健康检查重试配置（应对ELB/ASG启动延迟）
retry_strategy = Retry(
    total=3,
    backoff_factor=2,
    status_forcelist=[500, 502, 503, 504]
)

def lambda_handler(event, context):
    if not STACK_NAME:
        raise ValueError("STACK_NAME environment variable is not set")

    try:
        # 调用CloudFormation API获取栈信息
        stack_response = cfn_client.describe_stacks(StackName=STACK_NAME)
        stack_outputs = stack_response['Stacks'][0]['Outputs']

        # 提取ELB DNS名称（要和你CFN模板里的OutputKey完全一致）
        elb_dns = None
        for output in stack_outputs:
            if output['OutputKey'] == 'ELBDNSName':
                elb_dns = output['OutputValue']
                break

        if not elb_dns:
            raise Exception("Failed to find ELB DNS name in CloudFormation stack outputs")

        # 带重试的健康检查请求
        session = requests.Session()
        session.mount('http://', HTTPAdapter(max_retries=retry_strategy))
        health_check_url = f"http://{elb_dns}"
        response = session.get(health_check_url, timeout=15)
        
        # 验证状态码和页面内容（可选，根据你的需求调整）
        response.raise_for_status()
        if "Your Custom Index Content" not in response.text:
            raise Exception("Custom index.html content not found")

        print(f"✅ Health check passed! ELB URL: {health_check_url}, Status Code: {response.status_code}")
        return {
            'statusCode': 200,
            'body': f"Health check successful for ELB: {elb_dns}"
        }

    except Exception as e:
        print(f"❌ Health check failed: {str(e)}")
        raise e  # 抛出异常让流水线标记为失败

关键注意点： #

• 一定要确保STACK_NAME环境变量在Lambda配置中正确设置为你的CFN栈名称
• 代码里的OutputKey要和你CFN模板中定义的输出键完全匹配（比如你模板里写的是"OutputKey": "ELBDNSName"，这里就不能写错）
• 如果你的ELB用的是HTTPS，把URL改成https://{elb_dns}；如果是自签名证书可以加verify=False（生产环境不推荐）
• 重试逻辑很重要，因为ASG实例启动、HTTPD部署都需要时间，第一次请求可能会失败

三、流水线中集成Lambda阶段 #

假设你用的是AWS CodePipeline，第三阶段可以这么配置：

1. 添加一个自定义动作，提供者选择「AWS Lambda」
2. 选择你刚才创建的健康检查Lambda函数
3. 配置动作的输入：可以传递前一个部署阶段的栈名信息（比如通过流水线变量，或者从Deploy阶段的输出中提取）
4. 设置流水线的失败条件：如果Lambda执行抛出异常，流水线直接标记为失败，停止后续流程

如果是其他流水线工具，核心逻辑也是一样的：触发Lambda，传递必要参数，根据Lambda的执行结果判断流水线状态。

额外优化小技巧 #

• 可以在Lambda中添加对ASG实例状态的检查，确保至少有一个实例处于InService状态再做健康检查
• 把健康检查的超时时间、重试次数也做成环境变量，方便后续调整
• 用CloudWatch Alarms监控Lambda的失败次数，及时发现流水线问题

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