|
17 | 17 | # logger = tool.setupLogger(__name__, __name__ + '.log', 'w', logging.DEBUG) |
18 | 18 | logger =logging.getLogger('main') |
19 | 19 |
|
| 20 | +class time(object): |
| 21 | + time_units = { |
| 22 | + 'second': 's', |
| 23 | + 'minute': 'm', |
| 24 | + 'hour': 'h', |
| 25 | + 'day': 'D', |
| 26 | + 'week': 'W', |
| 27 | + 'month': 'M', |
| 28 | + 'year': 'Y' |
| 29 | + } |
| 30 | + |
| 31 | + def __init__(self, value, time_period): |
| 32 | + self.value = value |
| 33 | + self.time_period = time_period |
| 34 | + |
20 | 35 | class EditService(): |
21 | 36 | # Mutual exclusion: cursor, or connection_string |
22 | 37 | def __init__(self, series_id, connection=None, connection_string="", debug=False): |
@@ -142,13 +157,13 @@ def filter_date(self, before, after): |
142 | 157 | if before and after: |
143 | 158 | self.filtered_dataframe = df[(df.index < before) & (df.index > after)] |
144 | 159 |
|
145 | | - def fill_gap(self, gap, period): |
| 160 | + def fill_gap(self, gap, fill): |
146 | 161 |
|
147 | 162 | df = self.memDB.getDataValuesDF() |
148 | | - gaps= self.find_gaps(df, gap, period) |
| 163 | + gaps= self.find_gaps(df, gap[0], gap[1]) |
149 | 164 | points = [] |
150 | 165 | series= self.memDB.series |
151 | | - timegap = np.timedelta64(gap, self.time_units[period]) |
| 166 | + timegap = np.timedelta64(fill[0], self.time_units[fill[1]]) |
152 | 167 |
|
153 | 168 | #if gaps is not of type dataframe- put it in a dataframe |
154 | 169 | #if not isinstance(gaps, pd.DataFrame |
|
0 commit comments