2018/12/31抓取装置投运前两天的电流数据来判断通讯情况

阅读量：6335 次

发布时间：2019-06-22

本文共 2581 字，大约阅读时间需要 8 分钟。

目的：判断旧装置更换时在线情况

方法：通过一天所上传电流数据来对比；

1、按系统来抓取；

2、先在系统db库里将1832开头的装置编号与kid号获取到，列个表，然后拿着这个表在223里匹配投运时间，再将投运时间反推两天，再在his表里以kid和时间来匹配电流数据。最后加上判断。

一、SQL

1、筛选

二、SQL报错：刚开始怀疑是由于频繁连数据库导致访问遭拒绝，参考此报告后发现是SQL写错了。

File "G:/station/.idea/装置通讯断开情况.py", line 42, in <module>

cur.execute(check_sql3)

File "src\pymssql.pyx", line 465, in pymssql.Cursor.execute

pymssql.ProgrammingError: (102, b"Incorrect syntax near '4030000000001'.DB-Lib error message 20018, severity 15:\nGeneral SQL Server error: Check messages from the SQL Server\n")

三、脚本

-- coding:UTF-8 --

import os

import pymssql

import cx_Oracle

import arrow #导时间戳的模块

import xlwt

DEVICE = []

KID = []

TIME = []

os.environ['NLS_LANG'] = 'SIMPLIFIED CHINESE_CHINA.UTF8'

os.environ['NLS_LANG'] = 'AMERICAN_AMERICA.AL32UTF8'

conn = pymssql.connect(host=('****'), user='**', password='***', database='TAS3.2_DB_XA')

cur = conn.cursor()

check_sql1 = "SELECT liXHQDA21_DeviceID,sFactoryNum FROM XHQDA21_Device where sFactoryNum LIKE '1832%'" #DB库中拿装置编号与KID号

cur.execute(check_sql1)

A = cur.fetchall()

print(A)

for B in A:

c = B[1]

G = B[0]

DEVICE.append(c)

KID.append(G)

print(DEVICE)

for F in DEVICE:

print(F)

# 链接orcal库，获取投运时间tns = cx_Oracle.makedsn('***********, 'orcl')db = cx_Oracle.connect('*****', '***********', tns)cur = db.cursor()check_sql2 = "SELECT TIME_TOU FROM APP_DEVICE WHERE DEVICE_CODE = %s "%F    #总用户数量cur.execute(check_sql2)TIME_TOU = cur.fetchall()Datetime = TIME_TOU[0][0]TIME.append(Datetime)TIME_duan1 = arrow.get(Datetime).timestamp*1000 - 86400*2      #将datetime格式变为时间戳TIME_duan2 = arrow.get(Datetime).timestamp * 1000 - 86400 * 3# print(TIME_duan)