Cloud Monitor:ECS インスタンスの状態変更イベントに基づく O&M の自動化

イベントペイロードの構造

状態変更イベントは次の構造を使用します：

リスナーの作成

# -*- coding: utf-8 -*-
import logging
from .mns_client import BasicListener


class ListenerLog(BasicListener):
    def process(self, event):
        state = event['content']['state']
        resource_id = event['content']['resourceId']
        if state == 'Created':
            logging.info(f'The instance {resource_id} state is {state}')
        elif state == 'Deleted':
            logging.info(f'The instance {resource_id} state is {state}')

コンシューマーの実行

mns_client = MNSClient()

mns_client.regist_listener(ListenerLog())

mns_client.run()

結果の確認

1. コンソールで ECS インスタンスを作成またはリリースします。

2. コンシューマーのログで、The instance i-bp1abc... state is Created のようなメッセージを確認します。

本番環境では、stdout へのログ出力ではなく、データベースまたは Simple Log Service (SLS) にイベントを保存してください。これにより、過去のインスタンスライフサイクルデータを検索および監査できます。

リスナーの作成

手順 2 の MNS コンシューマーを再利用し、新しいリスナーを登録します：

# -*- coding: utf-8 -*-
import logging

from alibabacloud_ecs20140526.client import Client as Ecs20140526Client
from alibabacloud_ecs20140526.models import StartInstanceRequest
from alibabacloud_tea_openapi.models import Config

from .config import Conf
from .mns_client import BasicListener


class ECSClient(object):
    def __init__(self, client):
        self.client = client

    def start_instance(self, instance_id):
        logging.info(f'Start instance {instance_id} ...')
        request = StartInstanceRequest(
            instance_id=instance_id
        )
        self.client.start_instance(request)


class ListenerStart(BasicListener):
    def __init__(self):
        ecs_config = Config(
            access_key_id=Conf.access_key,
            access_key_secret=Conf.access_key_secret,
            endpoint=f'ecs.{Conf.region_id}.aliyuncs.com'
        )
        client = Ecs20140526Client(ecs_config)
        self.ecs_client = ECSClient(client)

    def process(self, event):
        detail = event['content']
        instance_id = detail['resourceId']
        if detail['state'] == 'Stopped':
            self.ecs_client.start_instance(instance_id)

コンシューマーの実行

mns_client = MNSClient()

mns_client.regist_listener(ListenerStart())

mns_client.run()

結果の確認

1. 実行中の ECS インスタンスを手動で停止します。

2. コンシューマーのログで、Start instance i-bp1abc... ... を確認します。

3. ECS コンソールでインスタンスの状態が Running に戻ることを確認します。

本番環境では、起動コマンドを発行した後の後続の状態遷移 (Starting、Running、Stopped) を監視してください。再起動に失敗するケースに備えて、タイマーとリトライカウンターを使用します。

リスナーの作成

手順 2 の MNS コンシューマーを再利用し、スポットインスタンスの割り込みイベント用のリスナーを登録します：

# -*- coding: utf-8 -*-
from alibabacloud_slb20140515.client import Client as Slb20140515Client
from alibabacloud_slb20140515.models import RemoveVServerGroupBackendServersRequest
from alibabacloud_tea_openapi.models import Config

from .config import Conf
from .mns_client import BasicListener


class SLBClient(object):
    def __init__(self):
        self.client = self.create_client()

    def create_client(self):
        config = Config()
        config.access_key_id = Conf.access_key
        config.access_key_secret = Conf.access_key_secret
        config.endpoint = 'slb.aliyuncs.com'
        return Slb20140515Client(config)

    def remove_vserver_group_backend_servers(self, vserver_group_id, instance_id):
        request = RemoveVServerGroupBackendServersRequest(
            region_id=Conf.region_id,
            vserver_group_id=vserver_group_id,
            backend_servers="[{'ServerId':'" + instance_id + "','Port':'80','Weight':'100'}]"
        )
        response = self.client.remove_vserver_group_backend_servers(request)
        return response


class ListenerSLB(BasicListener):
    def __init__(self, vserver_group_id):
        self.slb_caller = SLBClient()
        self.vserver_group_id = Conf.vserver_group_id

    def process(self, event):
        detail = event['content']
        instance_id = detail['instanceId']
        if detail['action'] == 'delete':
            self.slb_caller.remove_vserver_group_backend_servers(self.vserver_group_id, instance_id)

mns_client = MNSClient()

mns_client.regist_listener(ListenerSLB(Conf.vserver_group_id), 'Instance:PreemptibleInstanceInterruption')

mns_client.run()

スポットインスタンス割り込みイベントの構造

スポットインスタンスの割り込みイベントは、状態変更イベントとは異なるフィールド名を使用します：

結果の確認

1. スポットインスタンスの割り込みイベントを待機します (またはテスト環境でシミュレートします)。

2. 解放前にインスタンスが SLB の vServer グループから削除されていることを確認します。

本番環境では、サービス可用性を維持するために、代替のスポットインスタンスをリクエストし、直ちに SLB インスタンスにアタッチしてください。