123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869 |
- import json
- import re
- from memory_storage import MemoryStorage
- from hard_disk_storage import HardDiskStorage
- from configuration import Configuration
- class EventStorage:
- def __init__(self):
- self.config = Configuration().get_system_config()
- self.memoryStorage = MemoryStorage(self.config['memoryDatabase'])
- self.hardDiskStorage = HardDiskStorage(self.config['hardDiskdataBase'])
- def get_real_data(self, keys):
- data = self.memoryStorage.get_value(keys)
- return data
- def get_historical_data(self, select_info):
- data = self.hardDiskStorage.get_table_data(select_info)
- return data
- def real_time_data_storage(self, data):
- self.memoryStorage.set_value(data)
- def historical_data_storage(self, table_name, seve_time, data):
- self.hardDiskStorage.insert_column_many(table_name, seve_time, data)
- def get_connector_config(self):
- config = self.hardDiskStorage.get_connectors()
- for station_info in config:
- station_info['connector_config'] = json.loads(station_info['connector_config'])
- return config
- def get_station_info(self, station_name):
- return self.hardDiskStorage.get_station_info(station_name)
- def get_table_name(self):
- table_name = self.hardDiskStorage.get_table_name()
- return table_name
- # def table_xxx_insert_data(self, format_data_dict, table_name, save_time):
- # self.hardDiskStorage.table_xxx_insert_data(format_data_dict, table_name, save_time)
- def get_point_info(self, keys):
- point_list = []
- if keys:
- for key in keys:
- point_list.append(re.sub("\D", "", key))
- point_tuple = tuple(point_list)
- else:
- point_tuple = None
- return self.hardDiskStorage.get_point_info(point_tuple)
- # 获取modbus命令
- def get_command_info(self, station_name):
- return self.hardDiskStorage.get_command_info(station_name)
- # 执行sql语句
- def execute_sql(self, sql):
- result = self.hardDiskStorage.execute_sql(sql)
- return result
- def execute_update_sql(self, sql):
- """执行UPDATE、INSERT、DELETE语句"""
- return self.hardDiskStorage.execute_update_sql(sql)
- class Networkerror(RuntimeError):
- def __init__(self, arg):
- self.args = arg
|