FCでECSを自動起動&自動停止

作成日:2019-12-25

Function Compute(サーバレスアーキテクチャ)を使ってECSインスタンスを自動起動&自動停止させる

はじめに

本記事では、Alibaba CloudのFunction Compute(サーバレスアーキテクチャ)を使ってECSインスタンスを自動起動&自動停止させる方法をご紹介します。

この記事の目的

Alibaba CloudのFunctionComputeというサーバーレスでコードを実行できるプロダクトを使ってみます。 AWSでいうLambdaに相当するプロダクトで、低料金でAlibaba Cloudが提供するSDKなどを組み合わせてAlibaba CloudのリソースをAPIで操作することができます。

Function Computeで実現したいこと

従量課金で建てたECSを朝と夜の特定時間に自動起動ならびに自動停止させます。

背景としては、社内検証でECSを従量課金で複数台作りそのままにしておくことがあり、不使用時にもコストが発生していたことがもったいないと思ったからです。そして、FunctionComputeで実現する場合に、以下2点メリットが挙げられます。

・cron用のECSを別で用意したり、自身のPCをホストとしてタスクスケジューラーやcronを実施したりせずに、シンプルかつ低コストでAPIリクエストを投げられる
・Alibaba Cloud側で豊富なSDKを用意しており、使い慣れたプログラミング言語で開発できる

より柔軟にECSの自動停止と自動起動を実現させるために

ECSにはタグ機能があり、タグにはkeyとvalueを設定することが可能です。今回は、このタグのkeyを用いて、自動起動ならびに自動停止の対象とするECSを決定します。

keyの値はStart&Stopとして、タグを付けたECSとタグを付けていないECSで比較していきます。

タグっぽいアイコンがよりグレー色なECSが、タグなしのECSになります。

Function Computeの概要

Alibaba Cloud国際サイトのドキュメントセンターによると以下の通りです。

What is Function Compute?

Alibaba Cloud Function Compute is an event-driven and fully-managed compute service. With Function Compute, you can quickly build any type of applications or services without considering management or O&M. You can complete a set of backend services for processing multimedia data even in several days.

意訳

Alibaba CloudのFunctionComputeはイベント・ドリブンかつフルマネージドのコンピュートサービスである。 FunctionComputeを用いることで、迅速にいかなるタイプのアプリケーションまたはサービスをマネジメントやQ&Mを考慮せずに構築可能になる。複数のバックエンドサービスを僅かな日数で完了させることが可能。

How it works?

By using Function Compute, you can author and upload codes without worrying about procuring and managing infrastructure resources. Function Compute prepares computing resources for you and runs your codes on your behalf elastically and reliably. In addition, Function Compute provides log query, performance monitoring, alarms, and other features. You only pay for resources actually consumed when running the codes. No fee is incurred for application codes that are not run.

意訳

FunctionComputeを利用することで、インフラリソースの管理や入手を心配せずにコードの作成とアップロードが可能になる。 FunctionComputeは信頼性高く柔軟、（あなたの代わりに）コードを実行させるリソースを準備している。実際にコードを実行するにあたって消費したリソースのみの費用を支払う。実行していないアプリケーションコードの費用は請求されない。

なんとなくは伝わりますが、英語がちょっとアレで結構？な点が多いです。笑公式ドキュメントのイメージ図です。FunctionComputeがどうはたらくか、ワークフローが視覚的にわかりやすいです

現在、対応しているSDKのプログラミング言語（ランタイム）は以下です。

https://www.alibabacloud.com/help/doc-detail/53277.htm

SDKs for more languages are coming soon.とあるので、今後はRubyなども登場するのでしょうか？

Python3.xによる全体コード

自動起動と自動停止をインスタンスステータスに応じてif文で分岐させて1つのコードにまとめても良かったのですが、わかりやすくするためにfunctionごとに関数を分けました。

起動のスクリプト

#!/usr/bin/env python
#coding=utf-8

from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException
from aliyunsdkecs.request.v20140526.DescribeInstancesRequest import DescribeInstancesRequest
from aliyunsdkecs.request.v20140526.StartInstanceRequest import StartInstanceRequest
import json

# ACK情報、リージョン情報
ACCESSKEY_ID = ""
ACCESSKE_SECRET = ""
REGION_ID = "ap-northeast-1"
client = AcsClient(ACCESSKEY_ID, ACCESSKE_SECRET, REGION_ID)

# ハンドラー作成
def handler(event, context):
    describe_request = DescribeInstancesRequest()
    describe_request.set_Tags([
        {
            "Key": "Start&Stop"
            }
        ])

    execute_describe = client.do_action_with_exception(describe_request)
    data = json.loads(execute_describe)
    items = data['Instances']


    for instance in items['Instance']: 
        instanceid = instance['InstanceId']
        start_instance = StartInstanceRequest()
        start_instance.set_InstanceId(instanceid)
        start_instance_response = client.do_action_with_exception(start_instance)
        print(start_instance_response)

停止のスクリプト

#!/usr/bin/env python
#coding=utf-8

from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException
from aliyunsdkecs.request.v20140526.DescribeInstancesRequest import DescribeInstancesRequest
from aliyunsdkecs.request.v20140526.StopInstanceRequest import StopInstanceRequest
import json

# ACK情報、リージョン情報
ACCESSKEY_ID = ""
ACCESSKE_SECRET = ""
REGION_ID = "ap-northeast-1"
client = AcsClient(ACCESSKEY_ID, ACCESSKE_SECRET, REGION_ID)

# ハンドラー作成
def handler(event, context):
    describe_request = DescribeInstancesRequest()
    describe_request.set_Tags([
        {
            "Key": "Start&Stop"
            }
        ])
    execute_describe = client.do_action_with_exception(describe_request)
    data = json.loads(execute_describe)
    items = data['Instances']

    for instance in items['Instance']: 
        instanceid = instance['InstanceId']
        stop_instance = StopInstanceRequest()
        stop_instance.set_InstanceId(instanceid)
        stop_instance_response = client.do_action_with_exception(stop_instance)
        print(stop_instance_response)