diff --git a/data_reader.py b/data_reader.py index b39727f..682d908 100755 --- a/data_reader.py +++ b/data_reader.py @@ -12,13 +12,17 @@ #################################################################### import pymysql -import sys +import sys, os import re +import datetime + + # параметры соединения с СУБД db_host = 'host' db_user = 'dbuser' db_pass = 'dbpass' +out_dir = '/var/log/ats' def insert(**kwargs): """Вставка данных в БД. В качестве параметров список полей и значений""" @@ -47,6 +51,13 @@ def parce_string(line): return 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]) @@ -81,6 +92,7 @@ def parce_string(line): call_direct=call_direct) def port_data_read(port_name): + global out_dir """Чтение данных из последовательного порта, тестовая реализация""" import serial ser = serial.Serial(port_name)