| @@ -76,6 +76,12 class HDFReader(Reader, ProcessingUnit): | |||
|
|
76 | 76 | # extras=json.dumps(extras), |
|
|
77 | 77 | ) |
|
|
78 | 78 | |
|
|
79 | ATTENTION: | |
|
|
80 | Add attribute: | |
|
|
81 | ||
|
|
82 | utcoffset='-18000' | |
|
|
83 | in the last part of reader in order to work in Local Time | |
|
|
84 | ||
|
|
79 | 85 | """ |
|
|
80 | 86 | |
|
|
81 | 87 | __attrs__ = ['path', 'startDate', 'endDate', 'startTime', 'endTime', 'description', 'extras'] |
| @@ -96,7 +102,6 class HDFReader(Reader, ProcessingUnit): | |||
|
|
96 | 102 | self.utcoffset = 0 |
|
|
97 | 103 | |
|
|
98 | 104 | def setup(self, **kwargs): |
|
|
99 | ||
|
|
100 | 105 | self.set_kwargs(**kwargs) |
|
|
101 | 106 | if not self.ext.startswith('.'): |
|
|
102 | 107 | self.ext = '.{}'.format(self.ext) |
| @@ -179,13 +184,18 class HDFReader(Reader, ProcessingUnit): | |||
|
|
179 | 184 | thisTime = thisDatetime.time() |
|
|
180 | 185 | startUtcTime = (datetime.datetime.combine(thisDate, startTime) - datetime.datetime(1970, 1, 1)).total_seconds() |
|
|
181 | 186 | endUtcTime = (datetime.datetime.combine(thisDate, endTime) - datetime.datetime(1970, 1, 1)).total_seconds() |
|
|
182 | ||
|
|
183 | 187 | ind = numpy.where(numpy.logical_and(thisUtcTime >= startUtcTime, thisUtcTime < endUtcTime))[0] |
|
|
184 | if len(ind)==0: | |
|
|
185 | raise schainpy.admin.SchainError("[Reading] Date time selected invalid [%s - %s]: No *%s files in %s)" % (startTime, endTime, self.ext, self.path)) | |
|
|
186 | 188 | |
|
|
187 | 189 | self.blockList = ind |
|
|
188 | 190 | self.blocksPerFile = len(ind) |
|
|
191 | ||
|
|
192 | if len(ind)==0: | |
|
|
193 | print("[Reading] Block No. %d/%d -> %s [Skipping]" % (self.blockIndex, | |
|
|
194 | self.blocksPerFile, | |
|
|
195 | thisDatetime)) | |
|
|
196 | self.setNextFile() | |
|
|
197 | self.readFirstHeader() | |
|
|
198 | ||
|
|
189 | 199 | return |
|
|
190 | 200 | |
|
|
191 | 201 | def __readMetadata(self): |
General Comments 0
You need to be logged in to leave comments.
Login now