From 1b3684cb2080421ea433f3c8ded5f6e99b33b21c Mon Sep 17 00:00:00 2001
From: pcain-usgs <pcain@usgs.gov>
Date: Thu, 17 Dec 2020 16:21:50 -0700
Subject: [PATCH] convert namespace arguments to obsrio arguments
---
geomagio/processing/obsrio.py | 25 ++++++++++++++++++++++---
1 file changed, 22 insertions(+), 3 deletions(-)
diff --git a/geomagio/processing/obsrio.py b/geomagio/processing/obsrio.py
index 0c29fb8a7..2ffa33cc1 100644
--- a/geomagio/processing/obsrio.py
+++ b/geomagio/processing/obsrio.py
@@ -1,11 +1,17 @@
import os
from typing import Optional
+from argparse import Namespace
import typer
from ..algorithm import Algorithm, FilterAlgorithm
from ..edge import EdgeFactory, MiniSeedFactory
-from ..Controller import Controller, get_realtime_interval
+from ..Controller import (
+ Controller,
+ get_input_factory,
+ get_output_factory,
+ get_realtime_interval,
+)
from ..TimeseriesFactory import TimeseriesFactory
from .factory import get_edge_factory, get_miniseed_factory
@@ -16,13 +22,26 @@ def main():
def filter_realtime(
observatory: str,
- input_factory: Optional[TimeseriesFactory] = None,
- output_factory: Optional[TimeseriesFactory] = None,
+ input_factory: str = "miniseed",
+ host: str = "127.0.0.1",
+ port: str = 2061,
+ output_factory: str = "edge",
+ write_port: int = 2061,
realtime_interval: int = 600,
update_limit: int = 10,
):
"""Filter 10Hz miniseed, 1 second, one minute, and temperature data.
Defaults set for realtime processing; can also be implemented to update legacy data"""
+
+ args = Namespace()
+ args.input = input_factory
+ args.input_host = host
+ args.input_port = port
+ args.output = output_factory
+ args.output_port = write_port
+ input_factory = get_input_factory(args)
+ output_factory = get_output_factory(args)
+
obsrio_tenhertz(
observatory, realtime_interval, input_factory, output_factory, update_limit
)
--
GitLab