Skip to content
Snippets Groups Projects
Commit 2dfbe59d authored by Patrick Godwin's avatar Patrick Godwin
Browse files

gstlal_feature_aggregator, gstlal_feature_monitor: add option to connect to influx with auth, https

parent 6b1474fc
No related branches found
No related tags found
No related merge requests found
...@@ -64,6 +64,8 @@ def parse_command_line(): ...@@ -64,6 +64,8 @@ def parse_command_line():
group.add_option("--influx-hostname", help = "Specify the hostname for the influxDB database. Required if --data-backend = influx.") group.add_option("--influx-hostname", help = "Specify the hostname for the influxDB database. Required if --data-backend = influx.")
group.add_option("--influx-port", help = "Specify the port for the influxDB database. Required if --data-backend = influx.") group.add_option("--influx-port", help = "Specify the port for the influxDB database. Required if --data-backend = influx.")
group.add_option("--influx-database-name", help = "Specify the database name for the influxDB database. Required if --data-backend = influx.") group.add_option("--influx-database-name", help = "Specify the database name for the influxDB database. Required if --data-backend = influx.")
group.add_option("--enable-auth", default=False, action="store_true", help = "If set, enables authentication for the influx aggregator.")
group.add_option("--enable-https", default=False, action="store_true", help = "If set, enables HTTPS connections for the influx aggregator.")
group.add_option("--data-type", metavar = "string", help="Specify datatypes to aggregate from 'min', 'max', 'median'. Default: max") group.add_option("--data-type", metavar = "string", help="Specify datatypes to aggregate from 'min', 'max', 'median'. Default: max")
group.add_option("--num-processes", type = "int", default = 2, help = "Number of processes to use concurrently, default 2.") group.add_option("--num-processes", type = "int", default = 2, help = "Number of processes to use concurrently, default 2.")
parser.add_option_group(group) parser.add_option_group(group)
...@@ -116,6 +118,8 @@ class StreamAggregator(object): ...@@ -116,6 +118,8 @@ class StreamAggregator(object):
hostname=options.influx_hostname, hostname=options.influx_hostname,
port=options.influx_port, port=options.influx_port,
db=options.influx_database_name, db=options.influx_database_name,
auth=options.enable_auth,
https=options.enable_https,
reduce_across_tags=False, reduce_across_tags=False,
) )
else: ### hdf5 data backend else: ### hdf5 data backend
......
...@@ -65,6 +65,8 @@ def parse_command_line(): ...@@ -65,6 +65,8 @@ def parse_command_line():
group.add_option("--influx-hostname", help = "Specify the hostname for the influxDB database. Required if --data-backend = influx.") group.add_option("--influx-hostname", help = "Specify the hostname for the influxDB database. Required if --data-backend = influx.")
group.add_option("--influx-port", help = "Specify the port for the influxDB database. Required if --data-backend = influx.") group.add_option("--influx-port", help = "Specify the port for the influxDB database. Required if --data-backend = influx.")
group.add_option("--influx-database-name", help = "Specify the database name for the influxDB database. Required if --data-backend = influx.") group.add_option("--influx-database-name", help = "Specify the database name for the influxDB database. Required if --data-backend = influx.")
group.add_option("--enable-auth", default=False, action="store_true", help = "If set, enables authentication for the influx aggregator.")
group.add_option("--enable-https", default=False, action="store_true", help = "If set, enables HTTPS connections for the influx aggregator.")
group.add_option("--data-type", metavar="string", help="Specify datatypes to aggregate from 'min', 'max', 'median'. Default = max") group.add_option("--data-type", metavar="string", help="Specify datatypes to aggregate from 'min', 'max', 'median'. Default = max")
group.add_option("--num-processes", type = "int", default = 2, help = "Number of processes to use concurrently, default 2.") group.add_option("--num-processes", type = "int", default = 2, help = "Number of processes to use concurrently, default 2.")
parser.add_option_group(group) parser.add_option_group(group)
...@@ -121,6 +123,8 @@ class StreamMonitor(object): ...@@ -121,6 +123,8 @@ class StreamMonitor(object):
hostname=options.influx_hostname, hostname=options.influx_hostname,
port=options.influx_port, port=options.influx_port,
db=options.influx_database_name, db=options.influx_database_name,
auth=options.enable_auth,
https=options.enable_https,
reduce_across_tags=False, reduce_across_tags=False,
) )
else: ### hdf5 data backend else: ### hdf5 data backend
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment