svk/panasonic-log-reader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added backup data files procedure

Browse Source
This commit is contained in:
svk28 2017-08-01 10:09:28 +03:00
parent d672129fc5
commit b889adc00d
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
data_reader.py
View File

@ -12,13 +12,17 @@
#################################################################### ####################################################################
import pymysql import pymysql
import sys import sys, os
import re import re
import datetime
# параметры соединения с СУБД # параметры соединения с СУБД
db_host = 'host' db_host = 'host'
db_user = 'dbuser' db_user = 'dbuser'
db_pass = 'dbpass' db_pass = 'dbpass'
out_dir = '/var/log/ats'
def insert(**kwargs): def insert(**kwargs):
"""Вставка данных в БД. В качестве параметров список полей и значений""" """Вставка данных в БД. В качестве параметров список полей и значений"""
@ -47,6 +51,13 @@ def parce_string(line):
return return
print(line) print(line)
# Создаём текстовые файлы на всякий случай, для дублирования информации
now = datetime.datetime.now()
out_log_name = os.path.join(out_dir, '{}_{}'.format(now.month, now.year))
out_log = open(out_log_name,"a+")
out_log.write(line + '\n')
out_log.close()
# Разбор строки # Разбор строки
# Преобразуем дату к виду "ДД/ММ/ГГГГ" # Преобразуем дату к виду "ДД/ММ/ГГГГ"
#call_date = "{}.{}.20{}".format(line[:2],line[3:5],line[6:8]) #call_date = "{}.{}.20{}".format(line[:2],line[3:5],line[6:8])
@ -81,6 +92,7 @@ def parce_string(line):
call_direct=call_direct) call_direct=call_direct)
def port_data_read(port_name): def port_data_read(port_name):
global out_dir
"""Чтение данных из последовательного порта, тестовая реализация""" """Чтение данных из последовательного порта, тестовая реализация"""
import serial import serial
ser = serial.Serial(port_name) ser = serial.Serial(port_name)