您好,登錄后才能下訂單哦!
阿里云函數(shù)計(jì)算是一個(gè)事件驅(qū)動(dòng)的全托管計(jì)算服務(wù)。通過(guò)函數(shù)計(jì)算,您無(wú)需管理服務(wù)器等基礎(chǔ)設(shè)施,只需編寫(xiě)代碼并上傳。函數(shù)計(jì)算會(huì)為您準(zhǔn)備好計(jì)算資源,以彈性、可靠的方式運(yùn)行您的代碼,并提供日志查詢,性能監(jiān)控,報(bào)警等功能。借助于函數(shù)計(jì)算,您可以快速構(gòu)建任何類型的應(yīng)用和服務(wù),無(wú)需管理和運(yùn)維。更棒的是,您只需要為代碼實(shí)際運(yùn)行消耗的資源付費(fèi),而代碼未運(yùn)行則不產(chǎn)生費(fèi)用。
阿里云云監(jiān)控為云上用戶提供開(kāi)箱即用的企業(yè)級(jí)開(kāi)放型一站式監(jiān)控解決方案。涵蓋 IT 設(shè)施基礎(chǔ)監(jiān)控,外網(wǎng)網(wǎng)絡(luò)質(zhì)量撥測(cè)監(jiān)控,基于事件、自定義指標(biāo)、日志的業(yè)務(wù)監(jiān)控。為您全方位提供更高效、更全面、更省錢的監(jiān)控服務(wù)。
云監(jiān)控提供了豐富事件,并且事件還在不斷豐富中(云產(chǎn)品系統(tǒng)事件監(jiān)控), 豐富的事件觸發(fā)自定義處理的函數(shù),可以實(shí)現(xiàn)更加完美的的自動(dòng)化運(yùn)維。
假設(shè)兩臺(tái) ECS 機(jī)器A, B, A 機(jī)器出現(xiàn)了宕機(jī),這個(gè)時(shí)候需要把 A 機(jī)器上的 eip 遷移到備用機(jī)器 B 上,這個(gè)利用云監(jiān)控的報(bào)警和函數(shù)計(jì)算可以實(shí)現(xiàn)EIP的自動(dòng)遷移, 云監(jiān)控檢測(cè)到 A 宕機(jī)這個(gè)事件,然后觸發(fā)函數(shù)執(zhí)行,函數(shù)實(shí)現(xiàn) eip 的自動(dòng)遷移
創(chuàng)建函數(shù)(函數(shù)代碼在文末),函數(shù)創(chuàng)建可參考函數(shù)計(jì)算helloworld
注:記得給函數(shù)的 service 的 role 設(shè)置操作 ecs 和 eip 的權(quán)限
cdn.com/969096ef4233ea658e1ccf75686a7c4620269329.png">
模擬真實(shí)的 ecs 事件
# -*- coding: utf-8 -*-
import logging
import json, random, string, time
from aliyunsdkcore import client
from aliyunsdkvpc.request.v20160428.AssociateEipAddre***equest import AssociateEipAddre***equest
from aliyunsdkvpc.request.v20160428.UnassociateEipAddre***equest import UnassociateEipAddre***equest
from aliyunsdkvpc.request.v20160428.DescribeEipAddressesRequest import DescribeEipAddressesRequest
from aliyunsdkcore.auth.credentials import StsTokenCredential
LOGGER = logging.getLogger()
clt = None
def handler(event, context):
creds = context.credentials
sts_token_credential = StsTokenCredential(creds.access_key_id, creds.access_key_secret, creds.security_token)
'''
{
"product": "ECS",
"content": {
"executeFinishTime": "2018-06-08T01:25:37Z",
"executeStartTime": "2018-06-08T01:23:37Z",
"ecsInstanceName": "timewarp",
"eventId": "e-t4nhcpqcu8fqushpn3mm",
"eventType": "InstanceFailure.Reboot",
"ecsInstanceId": "i-bp18l0uopocfc98xxxx"
},
"resourceId": "acs:ecs:cn-hangzhou:123456789:instance/i-bp18l0uopocfc98xxxx",
"level": "CRITICAL",
"instanceName": "instanceName",
"status": "Executing",
"name": "Instance:SystemFailure.Reboot:Executing",
"regionId": "cn-hangzhou"
}
'''
evt = json.loads(event)
content = evt.get("content");
ecsInstanceId = content.get("ecsInstanceId");
regionId = evt.get("regionId");
global clt
clt = client.AcsClient(region_id=regionId, credential=sts_token_credential)
name = evt.get("name");
eipId = "eip-bp1nexxxc7zjfnex6i0";
standbyEcsId = "i-bp19yycxx7yroukxpv"
name = name.lower()
if name in ['Disk:Stalled:Executing'.lower(), 'Instance:SystemFailure.Reboot:Executing'.lower(), "Instance:InstanceFailure.Reboot:Executing".lower()]:
print("move eip to standbyEcs");
move_eip(ecsInstanceId, standbyEcsId, eipId) # move eip to standbyEcs
else:
# other event to do
pass
def getEipStatus(eip):
request = DescribeEipAddressesRequest()
request.set_AllocationId(eip)
request.add_query_param("RegionId", "cn-hangzhou")
response = _send_request(request)
if isinstance(response, dict) and "RequestId" in response:
EipAddresses = response.get('EipAddresses', {})
EipAddress = EipAddresses['EipAddress'][0]
status = EipAddress['Status']
return status
else:
LOGGER.error("getEipAddressDesc {} fail".format(eip))
def unAssociateEip(ecs_id, eip):
request = UnassociateEipAddre***equest()
request.set_AllocationId(eip)
request.set_InstanceType('EcsInstance')
request.set_InstanceId(ecs_id)
response = _send_request(request)
if isinstance(response, dict) and "RequestId" in response:
LOGGER.info("UnassociateEipAddress {} from {} succ".format(ecs_id, eip))
else:
LOGGER.error("UnassociateEipAddress {} from {} fail".format(ecs_id, eip))
def associateEip(ecs_id, eip):
associte_request = AssociateEipAddre***equest()
associte_request.set_AllocationId(eip)
associte_request.set_InstanceType('EcsInstance')
associte_request.set_InstanceId(ecs_id)
associte_response = _send_request(associte_request)
if isinstance(associte_response, dict) and "RequestId" in associte_response:
LOGGER.info("AssociateEipAddress {} to {} succ".format(eip, ecs_id))
return True
return False
def move_eip(from_ecs, to_ecs, eip):
unAssociateEip(from_ecs, eip)
# wait unAssociateEip ...
time.sleep(3)
# retry 30s util sucess
for i in xrange(10):
eip_status = getEipStatus(eip).lower()
if eip_status == 'available':
if associateEip(to_ecs, eip):
LOGGER.info("AssociateEipAddress {} to {} succ".format(eip, to_ecs))
return
else:
LOGGER.info("eip status = {}".format(eip_status))
time.sleep(3)
LOGGER.info("AssociateEipAddress {} to {} fail".format(eip, to_ecs))
# send open api request
def _send_request(request):
request.set_accept_format('json')
try:
response_str = clt.do_action_with_exception(request)
LOGGER.info(response_str)
response_detail = json.loads(response_str)
return response_detail
except Exception as e:
LOGGER.error(e)
“阿里巴巴云原生微信公眾號(hào)(ID:Alicloudnative)關(guān)注微服務(wù)、Serverless、容器、Service Mesh 等技術(shù)領(lǐng)域、聚焦云原生流行技術(shù)趨勢(shì)、云原生大規(guī)模的落地實(shí)踐,做最懂云原生開(kāi)發(fā)者的技術(shù)公眾號(hào)?!?/p>
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。