利用阿里云ECS运行Python脚本监测汽车车窗车门状态

简介: 利用阿里云CES运行脚本监测汽车车窗车门状态

1、购买阿里云服务器

https://www.aliyun.com/product/ecs

2、安装宝塔

yum install -ywget && wget-O install.sh http://download.bt.cn/install/install_6.0.sh && sh install.sh ed099927

3、编写脚本

①导入包

importrequestsimportjsonimportosimporttimeimportsmtplibfromemail.mime.textimportMIMETextfromemail.utilsimportformataddr

②请求登录接口

deflogin():
try:
url="######"payload=json.dumps({
"username": username,
"password": password        })
headers= {
'Host': 'api.xchanger.cn',
'Cookie': '###########',
'accept': 'application/json;responseformat=3',
'content-type': 'application/json',
'x-app-id': '##',
'user-agent': 'BackgroundShortcutRunner/1092.8.7 CFNetwork/1220.1 Darwin/20.3.0',
'accept-language': 'zh-cn'        }
response=requests.request("POST", url, headers=headers, data=payload,verify=False)
print(response.json())
accessToken=response.json()['data']['accessToken']
userId=response.json()['data']['userId']
withopen(r'login.txt', "w+") asf1:
f1.write(accessToken)
withopen(r'userId.txt', "w+") asf2:
f2.write(userId)
returnaccessTokenexceptExceptionasDamnMistake:
print(DamnMistake)
mail("登录错误",str(DamnMistake))

③请求车辆状态接口

defstatus(sessionToken):
ifos.path.exists(r'userId.txt'):
withopen(r'userId.txt', "r") asf:
userId=f.read()
else:
userId="#####"url="#####"+vin+"#####"+userIdpayload= {}
headers= {
'Host': 'api.xchanger.cn',
'Cookie': '#######',
'accept': 'application/json;responseformat=3',
'ecarx-net-platform': 'tsp',
'user-agent': '#########)',
'authorization': sessionToken,
'accept-language': 'zh-cn'    }
response=requests.request("GET", url, headers=headers, data=payload,verify=False)
try:
#数据更新日期updateTime=response.json()['data']['vehicleStatus']['updateTime']
updateTime=time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(response.json()['data']['vehicleStatus']['updateTime']/1000))
#左前车窗(2是关闭)winStatusDriver=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['climateStatus']['winStatusDriver']
#右前车窗(2是关闭)winStatusPassenger=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['climateStatus']['winStatusPassenger']
#左后车窗(2是关闭)winStatusDriverRear=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['climateStatus']['winStatusDriverRear']
#右后车窗(2是关闭)winStatusPassengerRear=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['climateStatus']['winStatusPassengerRear']
#冷却液是否正常(ture是正常)engineCoolantTemperatureValidity=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['runningStatus']['engineCoolantTemperatureValidity']
#后尾箱是否开启(1开启,0没有开启)trunkOpenStatus=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['trunkOpenStatus']
#引擎盖是否开启(1开启,0没有开启)engineHoodOpenStatus=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['engineHoodOpenStatus']
#左前门打开状态(0是关闭)doorOpenStatusDriver=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['doorOpenStatusDriver']
#右前门打开状态(0是关闭)doorOpenStatusPassenger=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['doorOpenStatusPassenger']
#左后门打开状态(0是关闭)doorOpenStatusDriverRear=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['doorOpenStatusDriverRear']
#右后门打开状态(0是关闭)doorOpenStatusPassengerRear=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['doorOpenStatusPassengerRear']
#左前门门锁状态(1是已上锁)doorLockStatusDriver=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['doorLockStatusDriver']
#左后门门锁状态(1是已上锁)doorLockStatusDriverRear=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['doorLockStatusDriverRear']
#右前门门锁状态(1是已上锁)doorLockStatusPassenger=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['doorLockStatusPassenger']
#右后门门锁状态(1是已上锁)doorLockStatusPassengerRear=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['doorLockStatusPassengerRear']
#车辆报警是否开启(1为已开启)vehicleAlarm=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['drivingSafetyStatus']['vehicleAlarm']
#电瓶电压voltage=response.json()['data']['vehicleStatus']['additionalVehicleStatus']['maintenanceStatus']['mainBatteryStatus']['voltage']
#发动机状态(engine_off为关闭,engine_running为开启)engineStatus=response.json()['data']['vehicleStatus']['basicVehicleStatus']['engineStatus']
carStatus_dict= {
"数据更新时间": updateTime,
"左前车窗": winStatusDriver,
"右前车窗": winStatusPassenger,
"左后车窗": winStatusDriverRear,
"右后车窗": winStatusPassengerRear,
"后尾箱是否开启": trunkOpenStatus,
"引擎盖是否开启": engineHoodOpenStatus,
"左前门打开状态": doorOpenStatusDriver,
"右前门打开状态": doorOpenStatusPassenger,
"左后门打开状态": doorOpenStatusDriverRear,
"右后门打开状态": doorOpenStatusPassengerRear,
"左前门门锁状态": doorLockStatusDriver,
"左后门门锁状态": doorLockStatusDriverRear,
"右前门门锁状态": doorLockStatusPassenger,
"右后门门锁状态": doorLockStatusPassengerRear,
"车辆报警是否开启": vehicleAlarm,
"电瓶电压": voltage,
"发动机状态": engineStatus        }
withopen(r'carStatus_dict.txt', "w+") asf:
f.write(str(carStatus_dict))
returncarStatus_dictexceptExceptionasDamnMistake:
print(DamnMistake)
mail("获取各项数据错误",str(DamnMistake))


⑤发送邮件

defmail(msgTitle, result_json):
my_sender='####@qq.com'# 发件人邮箱账号my_pass='####'# 发件人邮箱密码my_user='#####@qq.com'# 收件人邮箱账号try:
msg=MIMEText(json.dumps(result_json, sort_keys=True, indent=4, separators=(',', ':'), ensure_ascii=False),
'plain', 'utf-8')
msg['From'] =formataddr(["###", my_sender])  # 括号里的对应发件人邮箱昵称、发件人邮箱账号msg['To'] =formataddr(["FK", my_user])  # 括号里的对应收件人邮箱昵称、收件人邮箱账号msg['Subject'] =msgTitle# 邮件的主题server=smtplib.SMTP_SSL("smtp.qq.com", 465)  # 发件人邮箱中的SMTP服务器,端口是25server.login(my_sender, my_pass)  # 括号中对应的是发件人邮箱账号、邮箱密码server.sendmail(my_sender, my_user, msg.as_string())  # 括号中对应的是发件人邮箱账号、收件人邮箱账号、发送邮件server.quit()  # 关闭连接exceptExceptionasfuckError:  # 如果 try 中的语句没有执行,则会执行下面的print('发送邮件报错了,报错内容为:\n')
print(fuckError)

⑥主程序

defmain():
sessionToken=update_token()
carStatus_dict=status(sessionToken)
print(carStatus_dict)
car_Alarm=[]
ifcarStatus_dict['发动机状态'] =="engine_off":
ifcarStatus_dict['左前车窗'] !="2":
car_Alarm.append("左前车窗未关闭")
ifcarStatus_dict['右前车窗'] !="2":
car_Alarm.append("右前车窗未关闭")
ifcarStatus_dict['左后车窗'] !="2":
car_Alarm.append("左后车窗未关闭")
ifcarStatus_dict['右后车窗'] !="2":
car_Alarm.append("右后车窗未关闭")
ifcarStatus_dict['后尾箱是否开启'] =="1":
car_Alarm.append("后尾箱未关闭")
ifcarStatus_dict['左前门门锁状态'] !="1":
car_Alarm.append("左前门未锁")
ifcarStatus_dict['左后门门锁状态'] !="1":
car_Alarm.append("左后门未锁")
ifcarStatus_dict['右前门门锁状态'] !="1":
car_Alarm.append("右前门未锁")
ifcarStatus_dict['右后门门锁状态'] !="1":
car_Alarm.append("右后门未锁")
ifcarStatus_dict['左前门打开状态'] =="1":
car_Alarm.append("左前门未关闭")
ifcarStatus_dict['左后门打开状态'] =="1":
car_Alarm.append("左后门未关闭")
ifcarStatus_dict['右前门打开状态'] =="1":
car_Alarm.append("右前门未关闭")
ifcarStatus_dict['右后门打开状态'] =="1":
car_Alarm.append("右后门未关闭")
print(car_Alarm)
else:
passiflen(car_Alarm)>0:
car_Alarm.append("数据更新时间:"+carStatus_dict['数据更新时间'])
withopen(r'car_Alarm.txt', "w+") asf1:
f1.write(str(car_Alarm))
mail("车辆报警!!!!!!", car_Alarm)


4、上传脚本

①打开宝塔

②点击“文件”

③上传

image.png

5、开启定时任务

①打开宝塔

②点击“计划任务”

image.png

6、结束

image.png

image.png































相关实践学习
借助OSS搭建在线教育视频课程分享网站
本教程介绍如何基于云服务器ECS和对象存储OSS,搭建一个在线教育视频课程分享网站。
7天玩转云服务器
云服务器ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,可降低 IT 成本,提升运维效率。本课程手把手带你了解ECS、掌握基本操作、动手实操快照管理、镜像管理等。了解产品详情: https://www.aliyun.com/product/ecs
相关文章
|
1月前
|
监控 Apache
HAProxy的高级配置选项-Web服务器状态监测
这篇文章介绍了HAProxy的高级配置选项,特别是如何进行Web服务器状态监测,包括基于四层传输端口监测、基于指定URI监测和基于指定URI的request请求头部内容监测三种方式,并通过实战案例展示了配置过程和效果。
60 8
HAProxy的高级配置选项-Web服务器状态监测
|
26天前
|
消息中间件 关系型数据库 数据库
Python实时监测数据库表数据变化的方法
在实现时,需要考虑到应用的实时性需求、数据库性能影响以及网络延迟等因素,选择最适合的方法。每种方法都有其适用场景和限制,理解这些方法的原理和应用,将帮助开发者在实际项目中做出最合适的技术选择。
88 17
|
1月前
|
网络协议
keepalived对后端服务器的监测方式实战案例
关于使用keepalived进行后端服务器TCP监测的实战案例,包括配置文件的编辑和keepalived服务的重启,以确保配置生效。
38 1
keepalived对后端服务器的监测方式实战案例
|
1天前
|
网络协议 Python
Python创建一个TCP服务器
Python创建一个TCP服务器
|
1月前
|
机器学习/深度学习 数据采集 TensorFlow
使用Python实现深度学习模型:智能健康监测与预警
使用Python实现深度学习模型:智能健康监测与预警
93 9
|
26天前
|
机器学习/深度学习 数据可视化 搜索推荐
使用Python实现深度学习模型:智能睡眠监测与分析
使用Python实现深度学习模型:智能睡眠监测与分析
95 2
|
1月前
|
安全 Python
使用Python实现简单的Web服务器
使用Python实现简单的Web服务器
26 6
|
2月前
|
运维 监控 数据库
自动化运维:使用Python脚本实现服务器监控
【8月更文挑战第31天】在这篇文章中,我们将探索如何利用Python编写简单的脚本来实现对服务器的基本监控。通过学习和应用这些技术,你可以快速检测服务器的状态,包括CPU使用率、内存占用和磁盘空间等关键指标。这不仅有助于及时发现问题,还能提升运维效率。文章将逐步引导你理解监控的重要性,并展示如何从零开始构建自己的监控工具。
|
2月前
|
Shell 网络安全 数据安全/隐私保护
使用 Python 远程登陆服务器的最佳实践
使用 Python 远程登陆服务器的最佳实践
|
2月前
|
机器学习/深度学习 数据采集 传感器
使用Python实现深度学习模型:智能水质监测与管理
使用Python实现深度学习模型:智能水质监测与管理
68 1