Add ssl and verify_ssl arguments to support HTTPS

Author: BrianJKoopman

docs/agents/influxdb_publisher.rst

@@ -34,6 +34,8 @@ Add an InfluxDBAgent to your OCS configuration file::
                      '--port', 8086,
                      '--protocol', 'line',
                      '--gzip', True,
+                     '--ssl', False,
+                     '--verify-ssl', False,
                      '--database', 'ocs_feeds']},
 
 Docker Compose

ocs/agents/influxdb_publisher/agent.py

@@ -95,6 +95,8 @@ def record(self, session: ocs_agent.OpSession, params):
                               self.incoming_data,
                               port=self.args.port,
                               protocol=self.args.protocol,
+                              ssl=self.args.ssl,
+                              verify_ssl=self.args.verify_ssl,
                               gzip=self.args.gzip,
                               operate_callback=lambda: self.aggregate,
                               )
@@ -145,6 +147,14 @@ def make_parser(parser=None):
                         choices=['json', 'line'],
                         help="Protocol for writing data. Either 'line' or "
                              "'json'.")
+    pgroup.add_argument('--ssl',
+                        type=bool,
+                        default=False,
+                        help="Use https instead of http to connect to InfluxDB, defaults to False.")
+    pgroup.add_argument('--verify-ssl',
+                        type=bool,
+                        default=False,
+                        help="Verify SSL certificates for HTTPS requests, defaults to False.")
     pgroup.add_argument('--gzip',
                         type=bool,
                         default=False,

ocs/agents/influxdb_publisher/drivers.py

@@ -60,6 +60,8 @@ class _InfluxDBClientArgs:
     port: int
     username: str
     password: str
+    ssl: bool
+    verify_ssl: bool
     gzip: bool
 
 
@@ -81,6 +83,10 @@ class Publisher:
             port for InfluxDB instance, defaults to 8086.
         protocol (str, optional):
             Protocol for writing data. Either 'line' or 'json'.
+        ssl (bool, optional):
+            Use https instead of http to connect to InfluxDB, defaults to False.
+        verify_ssl (bool, optional):
+            Verify SSL certificates for HTTPS requests, defaults to False.
         gzip (bool, optional):
             compress influxdb requsts with gzip
         operate_callback (callable, optional):
@@ -101,8 +107,16 @@ class Publisher:
 
     """
 
-    def __init__(self, host, database, incoming_data, port=8086, protocol='line',
-                 gzip=False, operate_callback=None):
+    def __init__(self,
+                 host,
+                 database,
+                 incoming_data,
+                 port=8086,
+                 protocol='line',
+                 ssl=False,
+                 verify_ssl=False,
+                 gzip=False,
+                 operate_callback=None):
         self.db = database
         self.incoming_data = incoming_data
         self.protocol = protocol
@@ -117,6 +131,8 @@ def __init__(self, host, database, incoming_data, port=8086, protocol='line',
             port=port,
             username=username,
             password=password,
+            ssl=ssl,
+            verify_ssl=verify_ssl,
             gzip=gzip)
         self.client = InfluxDBClient(**asdict(self.client_args))