日常使用 NAS 过程中，偶尔会出现家里断电或者断网的情况，NAS 自带网络断开的通知功能，但需要是恢复网络链接后才会通知，而此时都恢复了，再通知也就没那么重要，还有断电情况下也是需要回家才能知道，断电保护可以使用 UPS，当停电后 UPS 通过 usb 数据线会给 NAS 发送通知，NAS 收到通知后在设定时间内关机并发送 ups 进入电池供电模式的通知，但这个方式需要购买 ups 设备，成本在 300 元左右。
image
注册中心原理
联想到注册中心等其他集群模式下的心跳连接，心跳超时则进行剔除的方式，自己便用 python 写了一个简单的 web 服务当作注册中心，再写一个定时任务每隔 5 秒扫描一遍最近注册时间数据，对比下来如果超时 60 秒以上，则认为 NAS 已经失去链接，立刻发送邮件/钉钉通知，当 NAS 重新上线连接后，定时任务扫描到注册信息会再发送已经连接的通知信息。
NAS 端原理
上文已经通过 python 提供了一个 web 服务，此时只需要在 NAS 端任务计划中创建一个每分钟的定时任务即可，定时请求心跳接口，服务端记录请求时间。
或者在 docker 里启动一个定时任务，crontab 命令
service cron start
*/1 * * * * curl http://ip:2580/register
服务端代码
启动 python 的命令，需要在后台运行
ps -ef|grep python
nohup python3 nas_health.py &
nohup python3 nas_register.py &
复制代码
nas_register-类似于注册中心的概念，提供一个 get 接口供 NAS 访问
# -*- encoding: utf-8 -*-import osimport datetimeimport tornado.web
class MainHandler(tornado.web.RequestHandler): def get(self): """get请求""" now = datetime.datetime.now() out = open("nas_datetime-" + str(now.year) + '-' + str(now.month) + '-' + str(now.day), 'a') out.write(str(now) + '\n') out.close() self.write("")
application = tornado.web.Application([(r"/register", MainHandler)], static_path=os.path.join(os.path.dirname(__file__), "static"), )
# 读取文件中的数据def read_txt_file(file_name): newFile = open(file_name) data = newFile.read() newFile.close() return data
if __name__ == "__main__": application.listen(2580) tornado.ioloop.IOLoop.instance().start()
复制代码
nas_health-定时扫描日志文件，对比注册时间
# -*- encoding: utf-8 -*-import datetimeimport timeimport smtplibfrom email.mime.text import MIMETextfrom email.header import Header
# 读取文件中的数据def read_txt_file(file_name): newFile = open(file_name) data = newFile.read() if data == '': return '' now = '' for line in data.split('\n'): if line == '': break now = line newFile.close() return now
def loop_monitor(): email_state = True while True: try: file_now = datetime.datetime.now() now_str = read_txt_file( "nas_datetime-" + str(file_now.year) + '-' + str(file_now.month) + '-' + str(file_now.day)) if now_str == '': continue now = datetime.datetime.strptime(str(now_str), "%Y-%m-%d %H:%M:%S.%f") now2 = datetime.datetime.now() print((now2 - now).seconds) if (now2 - now).seconds >= 60 and email_state: email("心跳已经超时", "xxx@xxx.com") email_state = False if (now2 - now).seconds < 60 and email_state == False: email_state = True email("心跳已经恢复", "xxx@xxx.com") except Exception as e: print("时间错误", e) time.sleep(5) # 暂停5秒
def email(text, toemail): sender = "xxx@xxx.com" # 发送方的邮箱 password = "xxxx." # 邮箱的授权码 receiver = toemail # 接收方的邮箱 data_time = time.strftime("%Y-%m-%d %H:%M:%S") subject = data_time + "Nas服务器心跳报警" # title邮件标题 words = text # text邮件内容 msg = MIMEText(words, 'plain', 'utf-8') # 中文需参数‘utf-8'，单字节字符不需要 msg['Subject'] = Header(subject, 'utf-8') # 邮件标题 msg['from'] = sender # 发信人地址 msg['to'] = receiver # 收信人地址 smtp = smtplib.SMTP_SSL("smtp.exmail.qq.com", 465) smtp.connect('smtp.exmail.qq.com') smtp.login(sender, password) smtp.sendmail(sender, receiver, msg.as_string()) smtp.quit()
if __name__ == "__main__": loop_monitor()
复制代码
image
评论