云服务器 ECS：通过云助手命令停止或重启实例

准备执行命令所需的信息。

1. 获取RAM用户的AccessKey。具体操作，请参见创建AccessKey。

2. 调用DescribeRegions获取地域列表，详细的参数说明，请参见DescribeRegions。

3. 调用DescribeInstances筛选符合指定条件的实例。详细的参数说明，请参见DescribeInstances。

在本地配置环境并运行示例代码。

1. 安装并升级阿里云Python SDK。

   sudo pip install --upgrade alibabacloud_ecs20140526

2. 创建.py文件，并写入示例代码。

   单击查看示例代码

   # coding=utf-8
   # If the Python sdk is not installed, run 'sudo pip install alibabacloud_ecs20140526'.
   # Make sure you're using the latest sdk version.
   # Run 'sudo pip install --upgrade alibabacloud_ecs20140526' to upgrade.
   
   import base64
   import logging
   import os
   import sys
   import time
   
   from alibabacloud_ecs20140526.client import Client as Ecs20140526Client
   from alibabacloud_ecs20140526.models import (
       DescribeInvocationResultsRequest,
       DescribeInstancesRequest,
       RunCommandRequest,
       RebootInstancesRequest
   )
   from alibabacloud_tea_openapi.models import Config
   
   # Configure the log output formatter
   logging.basicConfig(level=logging.INFO,
                       format="%(asctime)s %(name)s [%(levelname)s]: %(message)s",
                       datefmt='%m-%d %H:%M')
   
   logger = logging.getLogger()
   
   # 请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID 和 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
   # 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例使用环境变量获取 AccessKey 的方式进行调用，仅供参考，建议使用更安全的 STS 方式。
   access_key = os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID']
   access_key_secret = os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET']
   region_id = '<yourRegionId>'  # 请填入您获取的Region ID
   
   ecs_config = Config(
       access_key_id=access_key,
       access_key_secret=access_key_secret,
       endpoint=f'ecs.{region_id}.aliyuncs.com'
   )
   client = Ecs20140526Client(ecs_config)
   
   
   def base64_decode(content, code='utf-8'):
       if sys.version_info.major == 2:
           return base64.b64decode(content)
       else:
           return base64.b64decode(content).decode(code)
   
   
   def get_invoke_result(invoke_id):
       request = DescribeInvocationResultsRequest(
           region_id=region_id,
           invoke_id=invoke_id
       )
       response = client.describe_invocation_results(request)
       response_details = response.body.invocation.invocation_results.invocation_result
       dict_res = {detail.instance_id: {"status": detail.invocation_status,
                                        "output": base64_decode(detail.output)} for detail in
                   response_details}
       return dict_res
   
   
   def get_instances_status(instance_ids):
       request = DescribeInstancesRequest(
           region_id=region_id,
           instance_ids=str(instance_ids)
       )
       response = client.describe_instances(request)
       response_details = response.body.instances.instance
       dict_res = {detail.instance_id: {"status": detail.status} for detail in response_details}
       return dict_res
   
   
   def run_command(cmdtype, cmdcontent, instance_ids, timeout=60):
       """
       cmdtype: 命令类型： RunBatScript;RunPowerShellScript;RunShellScript
       cmdcontent: 命令内容
       instance_ids 实例ID列表
       """
       try:
           request = RunCommandRequest(
               region_id=region_id,
               type=cmdtype,
               command_content=cmdcontent,
               instance_id=instance_ids,
               timeout=timeout  # 执行命令的超时时间，单位s，默认是60s，请根据执行的实际命令来设置合适的超时时间
           )
           response = client.run_command(request)
           return response.body.invoke_id
       except Exception as e:
           logger.error("run command failed", exc_info=True)
   
   
   def reboot_instances(instance_ids, Force=False):
       """
       instance_ids: 需要重启的实例列表
       Force: 是否强制重启，默认否
       """
       request = RebootInstancesRequest(
           region_id=region_id,
           instance_id=instance_ids,
           force_reboot=Force
       )
       response = client.reboot_instances(request)
   
   
   def wait_invoke_finished_get_out(invoke_id, wait_count, wait_interval):
       for i in range(wait_count):
           result = get_invoke_result(invoke_id)
           if set([res['status'] for _, res in result.items()]) & set(["Running", "Pending", "Stopping"]):
               time.sleep(wait_interval)
           else:
               return result
       return result
   
   
   def wait_instance_reboot_ready(ins_ids, wait_count, wait_interval):
       for i in range(wait_count):
           result = get_instances_status(ins_ids)
           if set([res['status'] for _, res in result.items()]) != set(["Running"]):
               time.sleep(wait_interval)
           else:
               return result
       return result
   
   
   def run_task():
       # 设置云助手命令的命令类型
       cmdtype = "RunShellScript"
       # 设置云助手命令的命令内容
       cmdcontent = """
       #!/bin/bash
       echo helloworld
       """
       # 设置超时时间
       timeout = 60
       # 请填入需要执行命令并重启的实例的ID
       ins_ids = ["i-bp185fcs****", "i-bp14wwh****", "i-bp13jbr****"]
   
       # 执行命令
       invoke_id = run_command(cmdtype, cmdcontent, ins_ids, timeout)
       logger.info("run command,invoke-id:%s" % invoke_id)
   
       if invoke_id is None:
           logger.error("Failed to run command, stopping further execution")
           return
   
       # 等待命令执行完成，循环查询10次，每次间隔5秒，查询次数和间隔请根据实际情况配置
       invoke_result = wait_invoke_finished_get_out(invoke_id, 10, 5)
       for ins_id, res in invoke_result.items():
           logger.info(
               "instance %s command execute finished,status: %s,output:%s" % (ins_id, res['status'], res['output']))
   
       # 重启实例
       logger.warning("reboot instance Now")
       reboot_instances(ins_ids)
   
       time.sleep(5)
       # 等待实例重启至Running状态，循环查询30次，每次间隔10秒
       reboot_result = wait_instance_reboot_ready(ins_ids, 30, 10)
       logger.warning("reboot instance Finished")
       for ins_id, res in reboot_result.items():
           logger.info("instance %s status: %s" % (ins_id, res['status']))
   
   
   if __name__ == '__main__':
       run_task()
   

   请用您获取的信息替换示例代码中的以下信息：

   • AccessKey ID：access_key = os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID']

   • AccessKey Secret：access_key_secret = os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET']

   • Region ID：region_id = '<yourRegionId>'

   • 实例 ID：ins_ids= ["i-bp185fcs****","i-bp14wwh****","i-bp13jbr****"]

3. 运行.py文件。

   运行效果如下，对 3 台实例执行命令输出helloworld，然后自动重启实例：

   [root@iZxxx ~]# vim runcommand_reboot_instances.py
   [root@iZxxx ~]# ls
   runcommand_reboot_instances.py
   [root@iZxxx ~]# python runcommand_reboot_instances.py
   /usr/lib/python2.7/site-packages/aliyunsdkcore/auth/algorithm/sha_hmac256.py:20: CryptographyDeprecationWarning: Python 2 is now deprecated in cryptography, and will be removed in the next release.
     from cryptography.hazmat.backends import default_backend
   09-18 14:33 root [INFO]: run command,invoke-id:t-hz0xxxxx
   09-18 14:34 root [INFO]: instance i-bp185fcs**** command execute finished,status: Finished,output:helloworld
   
   09-18 14:34 root [INFO]: instance i-bp14wwh**** command execute finished,status: Finished,output:helloworld
   
   09-18 14:34 root [INFO]: instance i-bp13jbr**** command execute finished,status: Finished,output:helloworld
   
   09-18 14:34 root [WARNING]: reboot instance Now
   09-18 14:39 root [WARNING]: reboot instance Finished
   09-18 14:39 root [INFO]: instance i-bp185fcs**** status: Running
   09-18 14:39 root [INFO]: instance i-bp14wwh**** status: Running
   09-18 14:39 root [INFO]: instance i-bp13jbr**** status: Running

进入模板配置页面。

1. 登录OOS控制台。

2. 在左侧导航栏，单击自动化任务 > 自定义任务模板。

3. 单击创建模板。

完成模板配置。

1. 在创建模板页面，保持默认配置，然后单击下一步。

2. 单击YAML页签，并输入以下代码。

   单击查看示例代码

   FormatVersion: OOS-2019-06-01
   Description:
     en: Bulky run command on ECS instances and reboot instance.
     zh-cn: 批量在多台ECS实例上运行云助手命令并重启实例。
     name-en: ACS-ECS-BulkyRunCommandRboot
     name-zh-cn: 批量在ECS实例上运行命令并重启实例
     categories:
       - run_command
   Parameters:
     regionId:
       Type: String
       Description:
         en: The id of region
         zh-cn: 地域ID
       Label:
         en: Region
         zh-cn: 地域
       AssociationProperty: RegionId
       Default: '{{ ACS::RegionId }}'
     targets:
       Type: Json
       Label:
         en: TargetInstance
         zh-cn: 目标实例
       AssociationProperty: Targets
       AssociationPropertyMetadata:
         ResourceType: ALIYUN::ECS::Instance
         RegionId: regionId
     commandType:
       Description:
         en: The type of command
         zh-cn: 云助手命令类型
       Label:
         en: CommandType
         zh-cn: 云助手命令类型
       Type: String
       AllowedValues:
         - RunBatScript
         - RunPowerShellScript
         - RunShellScript
       Default: RunShellScript
     commandContent:
       Description:
         en: Command content to run in ECS instance
         zh-cn: 在ECS实例中执行的云助手命令
       Label:
         en: CommandContent
         zh-cn: 云助手命令
       Type: String
       MaxLength: 16384
       AssociationProperty: Code
       Default: echo hello
     workingDir:
       Description:
         en: 'The directory where the created command runs on the ECS instances.Linux instances: under the home directory of the administrator (root user): /root.Windows instances: under the directory where the process of the Cloud Assistant client is located, such asC:\Windows\System32.'
         zh-cn: 脚本在ECS实例中的运行目录。Linux系统实例默认在管理员（root用户）的home目录下，即/root。Windows系统实例默认在云助手Agent进程所在目录，例如C:\Windows\System32。
       Label:
         en: WorkingDir
         zh-cn: 运行目录
       Type: String
       Default: ''
     timeout:
       Description:
         en: The value of the invocation timeout period of a command on ECS instances
         zh-cn: ECS实例中执行命令的超时时间
       Label:
         en: Timeout
         zh-cn: 超时时间
       Type: Number
       Default: 600
     enableParameter:
       Description:
         en: Whether to include secret parameters or custom parameters in the command
         zh-cn: 命令中是否包含加密参数或自定义参数
       Label:
         en: EnableParameter
         zh-cn: 命令中是否包含加密参数或自定义参数
       Type: Boolean
       Default: false
     username:
       Description:
         en: The username that is used to run the command on the ECS instance
         zh-cn: 在ECS实例中执行命令的用户名称
       Label:
         en: Username
         zh-cn: 执行命令的用户名称
       Type: String
       Default: ''
     windowsPasswordName:
       Description:
         en: The name of the password used to run the command on a Windows instance
         zh-cn: 在Windows实例中执行命令的用户的密码名称
       Label:
         en: WindowsPasswordName
         zh-cn: 在Windows实例中执行命令的用户的密码名称
       Type: String
       Default: ''
       AssociationProperty: SecretParameterName
     rateControl:
       Description:
         en: Concurrency ratio of task execution
         zh-cn: 任务执行的并发比率
       Label:
         en: RateControl
         zh-cn: 任务执行的并发比率
       Type: Json
       AssociationProperty: RateControl
       Default:
         Mode: Concurrency
         MaxErrors: 0
         Concurrency: 10
     OOSAssumeRole:
       Description:
         en: The RAM role to be assumed by OOS
         zh-cn: OOS扮演的RAM角色
       Label:
         en: OOSAssumeRole
         zh-cn: OOS扮演的RAM角色
       Type: String
       Default: OOSServiceRole
   RamRole: '{{ OOSAssumeRole }}'
   Tasks:
     - Name: getInstance
       Description:
         en: Views the ECS instances.
         zh-cn: 获取ECS实例。
       Action: ACS::SelectTargets
       Properties:
         ResourceType: ALIYUN::ECS::Instance
         RegionId: '{{ regionId }}'
         Filters:
           - '{{ targets }}'
       Outputs:
         instanceIds:
           Type: List
           ValueSelector: Instances.Instance[].InstanceId
     - Name: runCommand
       Action: ACS::ECS::RunCommand
       Description:
         en: Execute cloud assistant command.
         zh-cn: 执行云助手命令。
       Properties:
         regionId: '{{ regionId }}'
         commandContent: '{{ commandContent }}'
         instanceId: '{{ ACS::TaskLoopItem }}'
         commandType: '{{ commandType }}'
         workingDir: '{{ workingDir }}'
         timeout: '{{ timeout }}'
         enableParameter: '{{ enableParameter }}'
         username: '{{ username }}'
         windowsPasswordName: '{{ windowsPasswordName }}'
       Loop:
         RateControl: '{{ rateControl }}'
         Items: '{{ getInstance.instanceIds }}'
         Outputs:
           commandOutputs:
             AggregateType: Fn::ListJoin
             AggregateField: commandOutput
       Outputs:
         commandOutput:
           Type: String
           ValueSelector: invocationOutput
     - Name: rebootInstance
       Action: ACS::ECS::RebootInstance
       Description:
         en: Restarts the ECS instances.
         zh-cn: 重启实例。
       Properties:
         regionId: '{{ regionId }}'
         instanceId: '{{ ACS::TaskLoopItem }}'
       Loop:
         RateControl: '{{ rateControl }}'
         Items: '{{ getInstance.instanceIds }}'
   Outputs:
     instanceIds:
       Type: List
       Value: '{{ getInstance.instanceIds }}'

3. 单击创建模板。

4. 在弹出的对话框中，输入模板名称runcommand_reboot_instances，然后单击完成创建。

执行模板。

1. 找到刚创建的模板，在操作列单击创建执行。

2. 完成执行配置。

   按提示逐步完成配置，在设置参数页面选择多台实例，其他设置保持默认即可。

   示例中设置参数如下：

   • 地域：选择华东1（杭州）

   • 目标实例：选择手动选择实例，单击选择实例添加需要执行命令的 ECS 实例

   • 云助手命令类型：选择RunShellScript

   • 云助手命令：输入echo hello

3. 在确定页面，单击创建。

   创建执行后自动开始执行模板，并跳转至执行的基本信息页面，等待执行状态变为成功后即执行完成。

查看任务执行过程和各任务节点执行详情。

1. 在执行步骤和结果区域，单击查看执行流程图查看执行过程。

   执行流程图显示任务依次经过获取 ECS 实例、执行云助手命令、重启实例三个步骤，均已执行成功。

2. 单击执行云助手命令，在循环任务列表页签下，查看各任务节点执行详情。可以看出预定动作均已成功完成。