Skip to content
Snippets Groups Projects

Do NOT "duplicate" raw 1-s data in EdgeCWB

1 file
+ 22
33
Compare changes
  • Side-by-side
  • Inline
@@ -200,38 +200,6 @@ def realtime_command(
realtime_interval=realtime_interval,
update_limit=update_limit,
)
_copy_channels(
# copy 1-sec ObsRIO channels
# NOTE: yes, this creates redundant data; however...
# - it is compressed
# - it is integer, so readable by EdgeFactory
# - it provides more "permanent" data, since the
# ObsRIO raw data *may* eventually get pruned
observatory=observatory,
channels=(
("LFF", "LFF"),
("LK1", "LK1"),
("LK2", "LK2"),
("LK3", "LK3"),
("LK4", "LK4"),
),
interval="second",
input_factory=MiniSeedFactory(
host=input_host,
port=None, # use MiniSeedFactory default
type="variation",
sncl_mode="geomag",
),
output_factory=EdgeFactory(
host=output_host,
port=output_read_port,
write_port=output_port,
type="variation",
sncl_mode="geomag",
),
realtime_interval=realtime_interval,
update_limit=update_limit,
)
# remove the following after data migration is complete
_copy_channels(
observatory=observatory,
@@ -258,7 +226,7 @@ def realtime_command(
minute_filter(
observatory=observatory,
channels=("U", "V", "W", "F", "T1", "T2", "T3", "T4"),
channels=("U", "V", "W"),
input_factory=EdgeFactory(
host=input_host,
port=input_port, # earthworm port required for realtime
@@ -275,6 +243,27 @@ def realtime_command(
realtime_interval=realtime_interval,
update_limit=update_limit,
)
# segregate F and T* filtering from U, V, and W until/unless ObsRio
# transmits scaled integer data
minute_filter(
observatory=observatory,
channels=("F", "T1", "T2", "T3", "T4"),
input_factory=MiniSeedFactory(
host=input_host,
port=None, # use MiniSeedFactory default
type="variation",
sncl_mode="geomag",
),
output_factory=EdgeFactory(
host=output_host,
port=output_read_port, # earthworm port required for realtime
write_port=output_port, # rawinput port required for realtime
type="variation",
sncl_mode="geomag",
),
realtime_interval=realtime_interval,
update_limit=update_limit,
)
# remove the following after data migration is complete
_copy_channels(
observatory=observatory,
Loading