Auto Scaling:Python 用 Alibaba Cloud SDK を使用してローリングアップデートタスクを実行する

手順 1: Python 用 Alibaba Cloud SDK をインストールする

1. 次のコマンドを実行して、Python 用 Alibaba Cloud SDK がインストールされているかどうかを確認します。

   python --version

   Python 用 Alibaba Cloud SDK がインストールされている場合、次の出力が表示されます。

2. 次のコマンドを実行して、OOS の依存関係をインストールします。

   pip install alibabacloud_oos20190601==3.2.1

手順 2: ローリングアップデートタスクを実行する

1. Python スクリプトを作成し、次のサンプルコードを入力してローリングアップデートタスクを実行します。

   コード内の OOS テンプレートパラメータについては、「テンプレートパラメータ」をご参照ください。サンプルコード:

   # -*- coding: utf-8 -*-
   import os
   import sys
   
   from typing import List
   
   from alibabacloud_oos20190601.client import Client as oos20190601Client
   from alibabacloud_tea_openapi import models as open_api_models
   from alibabacloud_oos20190601 import models as oos_20190601_models
   from alibabacloud_tea_util import models as util_models
   from alibabacloud_tea_util.client import Client as UtilClient
   
   
   class Sample:
       def __init__(self):
           pass
   
       @staticmethod
       def create_client() -> oos20190601Client:
           """
           AccessKey ID と AccessKey シークレットを使用してクライアントを初期化します。
           @return: Client
           @throws Exception
           """
           # プロジェクトコードが漏洩した場合、AccessKey ペアが漏洩し、Alibaba Cloud アカウントのすべてのリソースのセキュリティが侵害される可能性があります。次の行は参照用にのみ提供されています。
           config = open_api_models.Config(
               # 必須。 ALIBABA_CLOUD_ACCESS_KEY_ID 環境変数が構成されていることを確認してください。
               access_key_id=os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID'],
               # 必須。 ALIBABA_CLOUD_ACCESS_KEY_SECRET 環境変数が構成されていることを確認してください。
               access_key_secret=os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET']
           )
           config.endpoint = f'oos.cn-hangzhou.aliyuncs.com'
           return oos20190601Client(config)
   
       @staticmethod
       def main(
               args: List[str],
       ) -> None:
           client = Sample.create_client()
           tags = {
               'scaling_group': 'asg-bp1******'
           }
           start_execution_request = oos_20190601_models.StartExecutionRequest(
               region_id='cn-hangzhou',
               template_name='ACS-ESS-RollingUpdateByRunCommandInScalingGroup',
               parameters='''{"invokeType": "invoke",
                           "scalingGroupId": "asg-bp1******",
                           "commandType": "RunShellScript",
                           "invokeScript": "df -h;ifconfig",
                           "rollbackScript": "df -h;ifconfig",
                           "OOSAssumeRole": "",
                           "exitProcess": [
                               "ScaleIn",
                               "ScaleOut",
                               "HealthCheck",
                               "AlarmNotification",
                               "ScheduledAction"
                           ],
                           "enterProcess": [
                               "ScaleIn",
                               "ScaleOut",
                               "HealthCheck",
                               "AlarmNotification",
                               "ScheduledAction"
                           ],
                           "batchNumber": 2,
                           "batchPauseOption": "Automatic"}''',
               tags=tags
           )
           runtime = util_models.RuntimeOptions()
           try:
               # ビジネス要件に基づいて API オペレーションの応答を出力するコードを記述します。
               resp = client.start_execution_with_options(start_execution_request, runtime)
               print(resp.body)
           except Exception as error:
               # 実際のビジネスシナリオで例外を処理する場合は注意し、プロジェクトで例外を無視しないでください。この例では、エラーメッセージは参照用にのみ出力されます。
               # エラーメッセージを表示します。
               print(error.message)
               # トラブルシューティングに関する情報を表示します。
               print(error.data.get("Recommend"))
               UtilClient.assert_as_string(error.message)
   
   if __name__ == '__main__':
       Sample.main(sys.argv[1:])
   

2. Python スクリプトを実行し、応答を表示します。

   説明

   ロールバックタスクを実行する場合は、ソースローリングアップデートタスクの実行 ID を入力します。次の図に示すように、コマンド出力でソースローリングアップデートタスクの実行 ID などの情報を取得できます。

   

手順 3: (オプション) ロールバックタスクを実行する

ローリングアップデートタスクの実行時に例外が発生した場合、またはローリングアップデートタスクの実行後に以前の構成を使用する場合、ロールバックタスクを実行して ECS インスタンスの構成を復元できます。

1. Python スクリプトを作成し、次のサンプルコードを入力してロールバックタスクを実行します。

   コード内の OOS テンプレートパラメータについては、「テンプレートパラメータ」をご参照ください。サンプルコード:

   # -*- coding: utf-8 -*-
   import os
   import sys
   
   from typing import List
   
   from alibabacloud_oos20190601.client import Client as oos20190601Client
   from alibabacloud_tea_openapi import models as open_api_models
   from alibabacloud_oos20190601 import models as oos_20190601_models
   from alibabacloud_tea_util import models as util_models
   from alibabacloud_tea_util.client import Client as UtilClient
   
   
   class Sample:
       def __init__(self):
           pass
   
       @staticmethod
       def create_client() -> oos20190601Client:
           """
           AccessKey ID と AccessKey シークレットを使用してクライアントを初期化します。
           @return: Client
           @throws Exception
           """
           # プロジェクトコードが漏洩した場合、AccessKey ペアが漏洩し、Alibaba Cloud アカウントのすべてのリソースのセキュリティが侵害される可能性があります。次の行は参照用にのみ提供されています。
           config = open_api_models.Config(
               # 必須。 ALIBABA_CLOUD_ACCESS_KEY_ID 環境変数が構成されていることを確認してください。
               access_key_id=os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID'],
               # 必須。 ALIBABA_CLOUD_ACCESS_KEY_SECRET 環境変数が構成されていることを確認してください。
               access_key_secret=os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET']
           )
           config.endpoint = f'oos.cn-hangzhou.aliyuncs.com'
           return oos20190601Client(config)
   
       @staticmethod
       def main(
               args: List[str],
       ) -> None:
           client = Sample.create_client()
           tags = {
               'scaling_group': 'asg-bp1******'
           }
           start_execution_request = oos_20190601_models.StartExecutionRequest(
               region_id='cn-hangzhou',
               template_name='ACS-ESS-RollingUpdateByRunCommandInScalingGroup',
               parameters='''{"invokeType": "rollback",
                           "scalingGroupId": "asg-bp1******",
                           "commandType": "RunShellScript",
                           "rollbackScript": "df -h;ifconfig",
                           "OOSAssumeRole": "",
                           "sourceExecutionId": "exec-c1******",
                           "batchNumber": 2,
                           "batchPauseOption": "Automatic"}''',
               tags=tags
           )
           runtime = util_models.RuntimeOptions()
           try:
               # ビジネス要件に基づいて API オペレーションの応答を出力するコードを記述します。
               resp = client.start_execution_with_options(start_execution_request, runtime)
               print(resp.body)
           except Exception as error:
               # 実際のビジネスシナリオで例外を処理する場合は注意し、プロジェクトで例外を無視しないでください。この例では、エラーメッセージは参照用にのみ出力されます。
               # エラーメッセージを表示します。
               print(error.message)
               # トラブルシューティングに関する情報を表示します。
               print(error.data.get("Recommend"))
               UtilClient.assert_as_string(error.message)
   
   
   if __name__ == '__main__':
       Sample.main(sys.argv[1:])
   

2. Python スクリプトを実行し、応答を表示します。

   次の図は例を示しています。

テンプレートパラメータ