如何获取Auto Scaling Group实例变更通知及优化AMI升级脚本检测

你当前用的轮询方式存在局限性（比如单次定时器、异步逻辑处理不严谨），AWS提供了几种更可靠的替代方案，适配你使用的@aws-sdk/client-auto-scaling v3.635.0和@aws-sdk/client-ec2 v3.620.0版本：

1. 利用Auto Scaling生命周期钩子（Lifecycle Hooks） #

ASG的生命周期钩子可以在实例进入特定状态时触发通知，完美适配你等待新AMI实例就绪的场景：

• 配置钩子：针对EC2_INSTANCE_LAUNCHING状态设置钩子，当新实例启动后，ASG会暂停实例进入InService状态，直到你发送继续信号（或超时）
• 通知接收：将钩子的通知目标设置为SQS队列或SNS主题，你的脚本可以监听队列/主题，收到通知后验证实例状态（如应用是否就绪），再发送CompleteLifecycleAction让ASG完成实例注册

核心代码示例（创建钩子） #

import { AutoScalingClient, PutLifecycleHookCommand } from "@aws-sdk/client-auto-scaling";

const client = new AutoScalingClient({ region: "你的区域", credentials: 你的凭证 });

const input = {
  AutoScalingGroupName: "你的ASG名称",
  LifecycleHookName: "InstanceReadyHook",
  LifecycleTransition: "autoscaling:EC2_INSTANCE_LAUNCHING",
  NotificationTargetARN: "你的SQS/SNS ARN",
  RoleARN: "有权限发送通知的IAM角色ARN",
  HeartbeatTimeout: 300, // 等待你验证实例的超时时间（秒）
};

const command = new PutLifecycleHookCommand(input);
await client.send(command);

你的脚本只需监听SQS队列，收到消息后检查实例的应用状态，再调用CompleteLifecycleActionCommand即可。

2. 基于EventBridge监听实例状态事件 #

AWS EventBridge会推送EC2实例的状态变化事件，你可以通过规则匹配以下关键事件：

• EC2 Instance State-change Notification：实例进入running状态
• EC2 Instance Status Check Notification：实例系统/实例状态检查通过（代表实例本身就绪）
• Auto Scaling Instance Launch Successful：ASG完成实例启动并加入组

配置EventBridge规则将这些事件发送到SQS/SNS，你的脚本监听消息即可触发后续部署逻辑。

3. 使用SDK内置的Waiters替代自定义轮询 #

AWS SDK v3提供了Waiters功能，封装了可靠的轮询逻辑，无需自己手写定时器：

• 针对ASG实例，使用waitUntilInstanceInService等待器，直到实例进入InService状态（满足ASG的健康检查要求）
• 针对EC2实例，使用waitUntilInstanceRunning或waitUntilInstanceStatusOk等待器

核心代码示例（等待ASG实例就绪） #

import { AutoScalingClient, waitUntilInstanceInService } from "@aws-sdk/client-auto-scaling";

const client = new AutoScalingClient({ region: "你的区域", credentials: 你的凭证 });

// 先执行ASG扩容逻辑（设置期望实例数翻倍）
// ...

// 等待新实例进入InService状态
await waitUntilInstanceInService({
  client: client,
  maxWaitTime: 300, // 最长等待时间（秒）
  minDelay: 10, // 轮询间隔（秒）
}, {
  InstanceIds: ["新实例ID1", "新实例ID2"], // 你要等待的目标实例ID列表
});

// 实例就绪，执行后续应用部署逻辑

对你当前轮询代码的优化建议 #

你当前的代码存在几个问题：

• setTimeout仅执行一次，无法持续轮询，应改用setInterval
• {}.AutoScalingGroups是错误写法，应该用asgAfterUpdate.AutoScalingGroups
• 异步逻辑await getAutoScalingGroup放在setTimeout中会导致定时器无法正确处理异步结果

如果暂时不想改架构，至少要修复这些问题，比如：

const pollInterval = setInterval(async () => {
  const asgAfterUpdate = await getAutoScalingGroup(asgName, credentials, region);
  const allInstances = asgAfterUpdate.AutoScalingGroups?.[0].Instances || [];
  const readyInstances = allInstances.filter(instance => instance.LifecycleState === "InService");
  
  if (readyInstances.length >= myNewScalingSize) {
    clearInterval(pollInterval);
    // 执行后续部署逻辑
  }
}, 10000);

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