cmscore服务地址_cms core服务器
阿里云ECS在已有的系统事件的基础上,通过云监控新发布了状态变化类事件和抢占型实例的中断通知事件。每当ECS实例的状态发生变化的时候,都会触发一条ECS实例状态变化事件。这种变化包括您在控制台/OpenAPI/SDK操作导致的变化,也包括弹性伸缩或欠费等原因而自动触发的变化,还包括因为系统异常而触发的变化。
云监控以前发布的系统事件,主要针对告警后人工介入的场景,而这次新发布的事件属于正常类的信息通知,适合自动化的审计运维等场景。为了自动化处理ECS状态变化事件,云监控提供了两种主要途径:一种是通过函数计算,另一种是通过MNS消息队列。本文将为您介绍利用MNS消息队列自动化处理ECS事件的三种最佳实践。 自动化处理ECS状态变化事件的准备工作
创建消息队列
登录MNS控制台。
在队列列表页面,选择地域,单击右上角的创建队列,进入新建队列页面。
输入队列的名称(例如“ecs-cms-event”)等信息,单击确认即可完成创建消息队列。
创建事件报警规则
登录云监控控制台。
单击左侧导航栏中的事件监控,进入事件查询页面
单击报警规则页签,然后单击右上角的创建事件报警,弹出创建/修改事件报警对话框。
在基本信息区域,填写报警规则名称,例如如“ecs-test-rule”。
设置事件报警规则:选择事件类型为系统事件。
产品类型、事件等级、事件名称:产品类型选择云服务器ECS,事件类型选择StatusNotification,其余按照实际情况填写。
资源范围:选择全部资源时,任何资源发生相关事件,都会按照配置发送通知;选择应用分组时,只有指定分组内的资源发生相关事件时,才会发送通知。
在报警方式中,选择消息队列,然后选择地域和队列(例如ecs-cms-event)。
完成以上设置后,单击确定按钮即可完成创建事件报警规则。
安装Python依赖
本文所有的代码均使用Python 3.6测试通过,您也可以使用Java等其他编程语言。
请使用Pypi安装以下Python依赖:
aliyun-python-sdk-core-v3>=2.12.1
aliyun-python-sdk-ecs>=4.16.0
aliyun-mns>=1.1.5
自动化处理ECS状态变化事件的实施步骤
云监控会把云服务器ECS所有的状态变化事件都投递到MNS里面,接下来我们需要通过编写代码从MNS获取消息并进行消息处理。 实践一:对所有ECS的创建和释放事件进行记录
目前ECS控制台无法查询已经释放的实例。如果您有查询需求,可以通过ECS状态变化事件把所有ECS的生命周期记录在自己的数据库或者日志里。每当创建ECS时,会首先发送一个Pending事件,每当释放ECS时,会最后发送一个Deleted事件。我们需要对这两种事件进行记录。
编辑一个Conf文件。需包含mns的endpoint(可以登录MNS的控制台,在队列列表页,单击获取Endpoint得到)、阿里云的access key和secrect、region id(例如cn-beijing)以及mns queue的名字。
class Conf:
endpoint = 'http://.mns..aliyuncs.com/'
access_key = ''
access_key_secret = ''
region_id = 'cn-beijing'
queue_name = 'test'
vsever_group_id = ''
使用MNS的SDK编写一个MNS Client用来获取MNS消息。
# -*- coding: utf-8 -*-
import json
from mns.mns_exception import MNSExceptionBase
import logging
from mns.account import Account
from . import Conf
class MNSClient(object):
def __init__(self):
self.account = Account(Conf.endpoint, Conf.access_key, Conf.access_key_secret)
self.queue_name = Conf.queue_name
self.listeners = dict()
def regist_listener(self, listener, eventname='Instance:StateChange'):
if eventname in self.listeners.keys():
self.listeners.get(eventname).append(listener)
else:
self.listeners[eventname] = [listener]
def run(self):
queue = self.account.get_queue(self.queue_name)
while True:
try:
message = queue.receive_message(wait_seconds=5)
event = json.loads(message.message_body)
if event['name'] in self.listeners:
for listener in self.listeners.get(event['name']):
listener.process(event)
queue.delete_message(receipt_handle=message.receipt_handle)
except MNSExceptionBase as e:
if e.type == 'QueueNotExist':
logging.error('Queue %s not exist, please create queue before receive message.', self.queue_name)
else:
logging.error('No Message, continue waiting')
class BasicListener(object):
def process(self, event):
pass
上述代码只是对MNS消息进行拉取,调用Listener消费消息之后删除消息,后面的实践也会用到。
注册一个Listener进消费指定事件。这个简单的Listener判断收到Pending和Deleted事件时,打印一行日志。
# -*- 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 == 'Panding':
logging.info(f'The instance {resource_id} state is {state}')
elif state == 'Deleted':
logging.info(f'The instance {resource_id} state is {state}')
Main函数可以这么写:
mns_client = MNSClient()
mns_client.regist_listener(ListenerLog())
mns_client.run()
实际生产环境下,可能需要把事件存储在数据库里,或者利用SLS日志服务,方便后期的搜索和审计。
实践二:ECS的关机自动重启
在某些场景下,ECS会非预期的关机,您可能需要自动重启已经关机的ECS。
为了实现这一目的,我们复用实践一里面的MNS Client,添加一个新的Listener。当收到Stopped事件的时候,对该ECS执行一个Start命令。
-- coding: utf-8 --
import logging from aliyunsdkecs.request.v20140526 import StartInstanceRequest from aliyunsdkcore.client import AcsClient from .mns_client import BasicListener from .config import Conf
class ECSClient(object): def init(self, acs_client): self.client = acs_client
# 启动ECS实例
def start_instance(self, instance_id):
logging.info(f'Start instance {instance_id} ...')
request = StartInstanceRequest.StartInstanceRequest()
request.set_accept_format('json')
request.set_InstanceId(instance_id)
self.client.do_action_with_exception(request)
class ListenerStart(BasicListener): def init(self): acs_client = AcsClient(Conf.access_key, Conf.access_key_secret, Conf.region_id) self.ecs_client = ECSClient(acs_client)
def process(self, event):
detail = event['content']
instance_id = detail['resourceId']
if detail['state'] == 'Stopped':
self.ecs_client.start_instance(instance_id)
在实际生产环境下,执行完Start命令后,可能还需要继续接收后续的Starting/Running/Stopped等事件,再配合计时器和计数器,进行Start成功或失败之后的处理。 实践三:抢占型实例释放前,自动从SLB移除
抢占型实例在释放之前五分钟左右,会发出释放告警事件,您可以利用这短暂的时间运行一些业务不中断的逻辑。例如,主动从SLB的后端服务器中去掉这台即将被释放的抢占型实例,而不是被动等待实例释放后SLB的自动处理。
我们还是复用实践一的MNS Client,添加一个新的Listener,当收到抢占型实例的释放告警时,调用SLB的SDK。
-- coding: utf-8 --
from aliyunsdkcore.client import AcsClient from aliyunsdkcore.request import CommonRequest from .mns_client import BasicListener from .config import Conf
class SLBClient(object): def init(self): self.client = AcsClient(Conf.access_key, Conf.access_key_secret, Conf.region_id) self.request = CommonRequest() self.request.set_method('POST') self.request.set_accept_format('json') self.request.set_version('2014-05-15') self.request.set_domain('slb.aliyuncs.com') self.request.add_query_param('RegionId', Conf.region_id)
def remove_vserver_group_backend_servers(self, vserver_group_id, instance_id):
self.request.set_action_name('RemoveVServerGroupBackendServers')
self.request.add_query_param('VServerGroupId', vserver_group_id)
self.request.add_query_param('BackendServers',
"[{'ServerId':'" + instance_id + "','Port':'80','Weight':'100'}]")
response = self.client.do_action_with_exception(self.request)
return str(response, encoding='utf-8')
class ListenerSLB(BasicListener): def init(self, vsever_group_id): self.slb_caller = SLBClient() self.vsever_group_id = Conf.vsever_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.vsever_group_id, instance_id)
cmscore服务地址_cms core服务器相关推荐
- eShopOnContainers 是一个基于微服务的.NET Core示例框架
找到一个好的示例框架很难,但不是不可能.大多数是小型Todo风格的应用程序,通常基于SimpleCRUD.值得庆幸的是,Microsoft已经为eShopOnContainers创建了一个基于微服务的 ...
- 虚拟机看服务器mac地址,虚拟机修改服务器mac地址吗
虚拟机修改服务器mac地址吗 内容精选 换一换 本章节指导用户为Windows系统的ECS主机添加域名解析并添加安全组,防止下载Agent安装包与采集监控数据时出现异常.修改ECS的DNS配置有两种方 ...
- 内网PC通过NAT server公网地址访问内部服务器时TCP三次握手不成功
公网地址访问内部服务器时TCP三次握手不成功 一. 背景 在上图所示的网络中,PC 及Server属不同LAN,都是zone trust.为了让Internet用户能够访问到Server,FW上 ...
- 《Spring Cloud Netflix官方文档》2. 服务发现:Eureka服务器
2. 服务发现:Eureka服务器 2.1 如何创建Eureka服务器 引用org.springframework.cloud的spring-cloud-starter-eureka-server就可 ...
- Server 2008 Core/服务器核心环境安装SQL 2008 方法
查看了微软的文章,说SQL Server2012才支持,经过实验研究2008R2其实也是可以的,只是一些组件需要手动安装,以下方法适用于Microsoft SQL Server 2008和2008R2 ...
- ASP.NET Core服务器综述
ASP.NET Core应用通过一个进程内的HTTP服务器实例实现运行,这个服务器实例侦听HTTP请求并将请求作为组成HttpContext的一组请求功能集暴露给我们的应用程序. ASP.NET Co ...
- 如何修改服务器mac地址,如何修改服务器mac地址
如何修改服务器mac地址 内容精选 换一换 更新弹性云服务器的系统或者软件时,可以连接Internet,通过外部Pypi镜像源提供相关服务.但是,如果弹性云服务器无法访问Internet,或者外部Py ...
- NGINX配置基于Node.js服务的负载均衡服务器
NGINX配置基于Node.js服务的负载均衡服务器 本部署指南说明了如何使用NGINX开源和NGINX Plus在Node.js应用程序服务器池之间平衡HTTP和HTTPS通信.本指南中的详细说明适 ...
- win10系统配置服务器地址,win10系统配置服务器地址
win10系统配置服务器地址 内容精选 换一换 安装完操作系统后,需在当前iBMC远程管理界面中配置网卡IP地址才能远程连接服务器,配置方法如下.vi /etc/sysconfig/network-s ...
最新文章
- 思维导图学 Linux Shell攻略之小试牛刀篇
- python画人脸关键点
- 运动背景下的运动目标检测
- 缓存初解(四)---Ibatis的缓存配置+Ehcache
- Firefox下代码触发a标签的click事件无效
- 通用技术和信息技术合格考知识点_高二信息与通用技术会考知识点
- linux中创建目录树,如何在C/Linux中创建目录树?
- sublime怎么编译php,让sublime编译php、js
- 安装后jdk1.8 配置环境变量以后 版本显示还是1.7
- NYOJ 24 素数距离问题
- 一年前端的迷惑,深度还是广度
- 拉电阻、下拉电阻的原理和作用
- html登录用户名和密码验证码,JavaScript登录验证码的实现
- java当前日期_Java 获取当前日期的四种方法
- 做了这么多年的技术,你有写过博客吗?
- ant 编译java_java之ant编译
- 微信表情包小程序源码
- PotPlayer不支持S/W HEVC(H.265)解码怎么办?一招解决所有的不支持解码
- Codeforces Round #548 (Div. 2) 1139 D+2021天梯赛l3-3 解题报告(负二项式分布+莫比乌斯容斥+杜教筛(天梯赛))
- verilog分频电路