Skip to content
Snippets Groups Projects

_get_empty_channels method for ts factories

Files
4
+ 21
16
@@ -347,16 +347,15 @@ class EdgeFactory(TimeseriesFactory):
@@ -347,16 +347,15 @@ class EdgeFactory(TimeseriesFactory):
trace.data = trace.data.astype("i4")
trace.data = trace.data.astype("i4")
data.merge()
data.merge()
if data.count() == 0 and add_empty_channels:
if data.count() == 0 and add_empty_channels:
data += TimeseriesUtility.create_empty_trace(
data += self._get_empty_trace(
starttime,
starttime=starttime,
endtime,
endtime=endtime,
observatory,
observatory=observatory,
channel,
channel=channel,
type,
data_type=type,
interval,
interval=interval,
sncl.network,
network=sncl.network,
sncl.station,
location=sncl.location,
sncl.location,
)
)
self._set_metadata(data, observatory, channel, type, interval)
self._set_metadata(data, observatory, channel, type, interval)
return data
return data
@@ -469,20 +468,26 @@ class EdgeFactory(TimeseriesFactory):
@@ -469,20 +468,26 @@ class EdgeFactory(TimeseriesFactory):
ric.forceout()
ric.forceout()
ric.close()
ric.close()
def _set_metadata(self, stream, observatory, channel, type, interval):
def _set_metadata(
 
self,
 
stream: obspy.core.Stream,
 
observatory: str,
 
channel: str,
 
type: str,
 
interval: str,
 
):
"""set metadata for a given stream/channel
"""set metadata for a given stream/channel
Parameters
Parameters
----------
----------
observatory : str
observatory
observatory code
observatory code
channel : str
channel
edge channel code {MVH, MVE, MVD, ...}
edge channel code {MVH, MVE, MVD, ...}
type : str
type
data type {definitive, quasi-definitive, variation}
data type {definitive, quasi-definitive, variation}
interval : str
interval
interval length {minute, second}
interval length {minute, second}
"""
"""
for trace in stream:
for trace in stream:
self.observatoryMetadata.set_metadata(
self.observatoryMetadata.set_metadata(
trace.stats, observatory, channel, type, interval
trace.stats, observatory, channel, type, interval
Loading