new controller

Change-Id: Ib53332f702d2f5aa19ea6044f9ce02c9167f5c61
Issue-ID: DCAEGEN2-271
Signed-off-by: Ladue, David (dl3158) <dl3158@att.com>

8 files changed, 740 insertions, 0 deletions

diff --git a/src/mod/trapd_dcae_logger.py b/src/mod/trapd_dcae_logger.py
new file mode 100644
index 0000000..c47d8cf
--- /dev/null
+++ b/src/mod/trapd_dcae_logger.py
@@ -0,0 +1,68 @@
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+#
+"""
+NOTE:  This is a placeholder for now - logger has not been externalized
+from the main source.
+
+Setup custom logger for dcae_snmptrapd that incorporates
+a rotating file _handler with 10 backups of diagnostic messages
+:Parameters:
+
+:Exceptions:
+
+:Keywords:
+
+"""
+
+__docformat__ = 'restructuredtext'
+
+import logging
+
+
+# # # # # # # # # # # # # # # # # # #
+# fx: setup _dcae_logger custom logger
+# # # # # # # # # # ## # # # # # # #
+def setup_dcae_logger(_yc_snmptrapd_diag, _dcae_logger_max_bytes, _dcae_logger_num_archives):
+    """
+    """
+
+    _date_fmt = '%m/%d/%Y %H:%M:%S'
+
+    _yc_snmptrapd_diag_bak = "%s.bak" % (_yc_snmptrapd_diag)
+    if os.path.isfile(_yc_snmptrapd_diag):
+        os.rename(_yc_snmptrapd_diag, _yc_snmptrapd_diag_bak)
+
+    _handler = logging._handlers.RotatingFileHandler(_yc_snmptrapd_diag,
+                                                     maxBytes=_dcae_logger_max_bytes,
+                                                     backupCount=_dcae_logger_num_archives)
+
+    # set logLevel - valid values NOTSET, DEBUG, INFO, WARNING, ERROR, CRITICAL
+    _handler.setLevel(logging.DEBUG)
+    _dcae_logger.setLevel(logging.DEBUG)
+
+    log_fmt = '%(levelname)s|%(asctime)s|%(name)s|%(process)d|%(funcName)s|'\
+              '%(message)s'
+    _formatter = logging.Formatter(log_fmt)
+    _handler.setFormatter(formatter)
+    _dcae_logger.addHandler(_handler)
+
+    if os.path.isfile(_yc_snmptrapd_diag):
+        os.chmod(_yc_snmptrapd_diag, 0o640)
+
+    if os.path.isfile(_yc_snmptrapd_diag_bak):
+        os.chmod(_yc_snmptrapd_diag_bak, 0o640)
+
+    return _dcae_logger
diff --git a/src/mod/trapd_dmaap_config.py b/src/mod/trapd_dmaap_config.py
new file mode 100644
index 0000000..c764e52
--- /dev/null
+++ b/src/mod/trapd_dmaap_config.py
@@ -0,0 +1,104 @@
+# ============LICENSE_START=======================================================
+# org.onap.dcae
+# ================================================================================
+# Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
+# ================================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+#
+"""
+NOTE:  This module is for temporary use.  It will be removed when dcae_snmptrapd
+is migrated to the new controller infrastructure.
+
+trapd_dmaap_config is responsible for reading/parsing the previous generation
+'dmaap.conf' file, which includes stream, server and authentication details for
+publishing activities.
+"""
+
+__docformat__ = 'restructuredtext'
+
+import os
+import sys
+import string
+import time
+import traceback
+import collections
+import json
+
+from trapd_exit import cleanup_and_exit
+
+prog_name = os.path.basename(__file__)
+
+
+# # # # # # # # # # #
+# fx: read_dmaap_config
+# # # # # # # # # # #
+def read_dmaap_config(_yc_dmaap_conf, _dcae_logger):
+    # FIXME NOTE: This is for testing purposes only, and utilizes the
+    # previous generation of the controller; dispose of when ready
+    """
+    Load dmaap config /etc/dcae/dmaap.conf file (legacy controller)
+    :Parameters:
+      name of dmaap config file
+    :Exceptions:
+      file open
+        this function will throw an exception if unable to open
+        yc_dmaap_conf(fatal error)
+    :Keywords:
+      legacy controller dmaap.conf
+    :Variables:
+      yc_dmaap_conf
+        full path filename of dmaap_conf file provided by previous
+        generation controller
+    :Returns:
+      named tuple of config values
+    """
+
+    _dmaap_cfg_values_nt = collections.namedtuple('dmaap_config_values', [
+                                                  'dmaap_url', 'dmaap_user_name', 'dmaap_p_var', 'dmaap_stream_id', 'dmaap_host'])
+    if os.path.isfile(_yc_dmaap_conf):
+        _dcae_logger.debug('Reading DMaaP config file %s ' %
+                           _yc_dmaap_conf)
+    else:
+        _dcae_logger.error('DMaaP config file %s does NOT exist - exiting'
+                           % (_yc_dmaap_conf))
+        cleanup_and_exit(1, undefined)
+
+    with open(_yc_dmaap_conf) as _dmaap_config_fd:
+        _dmaapCfgData = json.load(_dmaap_config_fd)
+
+    try:
+        dmaap_url = _dmaapCfgData[0]["dmaapUrl"]
+        _dcae_logger.debug('dmaap_url: %s' % (dmaap_url))
+        dmaap_user_name = _dmaapCfgData[0]["dmaapUserName"]
+        _dcae_logger.debug('dmaap_user_name: %s' % (dmaap_user_name))
+        dmaap_p_var = _dmaapCfgData[0]["dmaapPassword"]
+        _dcae_logger.debug('dmaap_p_var: -')
+        dmaap_stream_id = _dmaapCfgData[0]["dmaapStreamId"]
+        _dcae_logger.debug('dmaap_stream_id: %s' % (dmaap_stream_id))
+    except:
+        _dcae_logger.error('DMaaP config file %s has missing data - exiting'
+                           % (_yc_dmaap_conf))
+        cleanup_and_exit(1, "undefined")
+
+    # This is for logging purposes only.
+    dmaap_host = dmaap_url.split('/')[2][:-5]
+    _dcae_logger.debug('dmaap_host: %s' % (dmaap_host))
+
+    _dmaap_config_fd.close()
+
+    _dmaap_cfg_values = _dmaap_cfg_values_nt(dmaap_url=dmaap_url, dmaap_user_name=dmaap_user_name,
+                                             dmaap_p_var=dmaap_p_var, dmaap_stream_id=dmaap_stream_id, dmaap_host=dmaap_host)
+    return _dmaap_cfg_values
diff --git a/src/mod/trapd_exit.py b/src/mod/trapd_exit.py
new file mode 100644
index 0000000..d14ea81
--- /dev/null
+++ b/src/mod/trapd_exit.py
@@ -0,0 +1,63 @@
+# ============LICENSE_START=======================================================
+# org.onap.dcae
+# ================================================================================
+# Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
+# ================================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+#
+"""
+trapc_exit_snmptrapd is responsible for removing any existing runtime PID
+file, and exiting with the provided (param 1) exit code
+"""
+
+__docformat__ = 'restructuredtext'
+
+import sys
+import os
+import string
+from trapd_runtime_pid import save_pid, rm_pid
+
+prog_name = os.path.basename(__file__)
+
+
+# # # # # # # # # # # # #
+# fx: cleanup_and_exit
+#      - remove pid file
+#      - exit with supplied return code
+# # # # # # # # # # # # #
+def cleanup_and_exit(_loc_exit_code, _pid_file_name):
+    """
+    Remove existing PID file, and exit with provided exit code
+    :Parameters:
+      _loc_exit_code
+        value to return to calling shell upon exit
+      _pid_file_name
+        name of file that contains current process ID (for
+        removal)
+    :Exceptions:
+      none
+    :Keywords:
+      runtime PID exit
+    :Variables:
+      _num_params
+        number of parameters passed to module
+    """
+
+    _num_params = len(locals())
+
+    if _num_params == 2:
+        rc = rm_pid(_pid_file_name)
+    sys.exit(_loc_exit_code)
diff --git a/src/mod/trapd_http_session.py b/src/mod/trapd_http_session.py
new file mode 100644
index 0000000..82c74b2
--- /dev/null
+++ b/src/mod/trapd_http_session.py
@@ -0,0 +1,62 @@
+# ============LICENSE_START=======================================================
+# org.onap.dcae
+# ================================================================================
+# Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
+# ================================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+#
+"""
+trapd_http_session establishes an http session for future use in publishing
+messages to the dmaap cluster.
+"""
+
+__docformat__ = 'restructuredtext'
+
+import logging
+import os
+import requests
+import string
+import time
+import traceback
+
+prog_name = os.path.basename(__file__)
+
+
+# # # # # # # # # # # # #
+# fx: init_session_obj
+# # # # # # # # # # # # #
+def init_session_obj(_dcae_logger):
+    """
+    Initializes and returns a http request session object for later use
+    :Parameters:
+      dcae logger for diagnostics
+    :Exceptions:
+      session object creation
+        this function will throw an exception if unable to create
+        a new session object
+    :Keywords:
+      http request session
+    :Variables:
+      none
+    """
+
+    try:
+        s = requests.Session()
+        _dcae_logger.debug("New requests session has been initialized: %s" % s)
+    except:
+        _dcae_logger.error("Failed to create new requests session")
+
+    return s
diff --git a/src/mod/trapd_perm_status.py b/src/mod/trapd_perm_status.py
new file mode 100644
index 0000000..5bf2180
--- /dev/null
+++ b/src/mod/trapd_perm_status.py
@@ -0,0 +1,61 @@
+# ============LICENSE_START=======================================================
+# org.onap.dcae
+# ================================================================================
+# Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
+# ================================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+#
+"""
+trapd_perm_status maintains a 'permanent' status file
+important messages for audit/diagnostics/etc
+"""
+
+__docformat__ = 'restructuredtext'
+
+import logging
+import os
+import string
+import time
+import traceback
+
+prog_name = os.path.basename(__file__)
+
+
+# # # # # # # # # # # # #
+# fx: log_to_perm_status
+# # # # # # # # # # # # #
+def log_to_perm_status(_loc_perm_file, _loc_perm_msg, _dcae_logger):
+    """
+    Log select errors too permanent logfile
+    access.
+    :Parameters:
+      log message, logger
+    :Exceptions:
+      file open
+        this function will catch exception of unable to
+        open the log file
+    :Keywords:
+      permstatus
+    """
+
+    perm_fmt_date = time.strftime("%a %b %d %H:%M:%S %Z %Y")
+
+    try:
+        f = open(_loc_perm_file, 'a')
+        f.write("%s %s\n" % (perm_fmt_date, _loc_perm_msg))
+        f.close()
+    except IOError:
+        _dcae_logger.exception("File I/O Exception on %s" % perm_status_fd)
diff --git a/src/mod/trapd_runtime_pid.py b/src/mod/trapd_runtime_pid.py
new file mode 100644
index 0000000..bddc63c
--- /dev/null
+++ b/src/mod/trapd_runtime_pid.py
@@ -0,0 +1,91 @@
+# ============LICENSE_START=======================================================
+# org.onap.dcae
+# ================================================================================
+# Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
+# ================================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+#
+"""
+trapd_runtime_pid maintains a 'PID file' (file that contains the
+PID of currently running trap receiver)
+"""
+
+__docformat__ = 'restructuredtext'
+
+import logging
+import os
+import string
+import time
+import traceback
+
+prog_name = os.path.basename(__file__)
+
+
+# # # # # # # # # # # # #
+# fx: save_pid - save PID of running process
+# # # # # # # # # # # # #
+def save_pid(_pid_file_name):
+    """
+    Save the current process ID in a file for external
+    access.
+    :Parameters:
+      none
+    :Exceptions:
+      file open
+        this function will catch exception of unable to
+        open/create _pid_file_name
+    :Keywords:
+      pid /var/run
+    """
+
+    try:
+        pid_fd = open(_pid_file_name, 'w')
+        pid_fd.write('%d' % os.getpid())
+        pid_fd.close()
+    except IOError:
+        print("IOError saving PID file %s :" % _pid_file_name)
+        return False
+    # except:
+    #     print("Error saving PID file %s :" % _pid_file_name)
+    #     return False
+    else:
+        print("Runtime PID file:    %s" % _pid_file_name)
+        return True
+
+
+# # # # # # # # # # # # #
+# fx: rm_pid - remove PID of running process
+# # # # # # # # # # # # #
+def rm_pid(_pid_file_name):
+    """
+    Remove the current process ID file before exiting.
+    :Parameters:
+      none
+    :Exceptions:
+      file open
+        this function will catch exception of unable to find or remove
+        _pid_file_name
+    :Keywords:
+      pid /var/run
+    """
+
+    try:
+        if os.path.isfile(_pid_file_name):
+            os.remove(_pid_file_name)
+        return True
+    except IOError:
+        print("Error removing Runtime PID file:    %s" % _pid_file_name)
+        return False
diff --git a/src/mod/trapd_trap_config.py b/src/mod/trapd_trap_config.py
new file mode 100644
index 0000000..bfcbb41
--- /dev/null
+++ b/src/mod/trapd_trap_config.py
@@ -0,0 +1,98 @@
+# ============LICENSE_START=======================================================
+# org.onap.dcae
+# ================================================================================
+# Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
+# ================================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+#
+"""
+trapd_trap_conf reads config file of traps and stores/returns them
+in a data dictionary that is used to compare arriving SNMP OID's
+to the list contained in this file for a keep(/publish) or ignore
+decision.
+"""
+
+__docformat__ = 'restructuredtext'
+
+import os
+import sys
+import string
+import time
+import traceback
+from trapd_exit import cleanup_and_exit
+
+
+prog_name = os.path.basename(__file__)
+
+
+# # # # # # # # # # #
+# fx: read_trap_config
+# # # # # # # # # # #
+
+def read_trap_config(_yc_trap_conf, _dcae_logger):
+    """
+    Load trap config file specified in yaml conf.  This config (1) specifies
+    which traps should be published(inclusion) and which traps should be discarded
+    (not present in config) and (2) maps SNMP Notify OID to DMAAP/MR topics
+    :Parameters:
+      none
+    :Exceptions:
+      file open
+        this function will throw an exception if unable to open
+        _yc_trap_conf
+    :Keywords:
+      NotifyOID trap config topic
+    :Variables:
+    """
+
+    _trap_conf_dict = {}
+
+    if os.path.isfile(_yc_trap_conf):
+        _dcae_logger.debug('Reading trap config file %s ' % _yc_trap_conf)
+    else:
+        _dcae_logger.error('ERROR:  trap config file %s does NOT exist - exiting'
+                           % (_yc_trap_conf))
+        cleanup_and_exit(1, "undefined")
+
+    # reset dictionaries in case we've been here before
+    _num_trap_conf_entries = 0
+
+    field_separator = " "
+
+    _dcae_logger.debug('processing trap config settings from %s'
+                       % (_yc_trap_conf))
+    for line in open(_yc_trap_conf):
+        # format:
+        #
+        # oid_including_regex <topic>
+        #
+        if line[0] != '#':
+            columns = line.rstrip().split(field_separator)
+            # process trap config entries
+            if len(columns) == 2:
+                _trap_conf_oid = columns[0]
+                _trap_conf_dict[_trap_conf_oid] = columns[1]
+                _dcae_logger.debug('%d oid: %s topic: %s' %
+                                   (_num_trap_conf_entries, _trap_conf_oid, _trap_conf_dict[_trap_conf_oid]))
+                _num_trap_conf_entries += 1
+            else:
+                _dcae_logger.debug('ERROR: Invalid trap config entry - '
+                                   'skipping: %s' % (line.rstrip()))
+
+    _dcae_logger.debug('%d trap config entries found in %s' % (_num_trap_conf_entries,
+                                                               _yc_trap_conf))
+
+    return _trap_conf_dict
diff --git a/src/mod/trapd_yaml_config.py b/src/mod/trapd_yaml_config.py
new file mode 100644
index 0000000..0041232
--- /dev/null
+++ b/src/mod/trapd_yaml_config.py
@@ -0,0 +1,193 @@
+# ============LICENSE_START=======================================================
+# org.onap.dcae
+# ================================================================================
+# Copyright (c) 2017 AT&T Intellectual Property. All rights reserved.
+# ================================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+#
+"""
+Read the SNMP trap receiver YAML config file, which contains the vast
+majority of configurable parameters for the process, including
+location of other config files, http timeouts, dns cache times,
+etc.
+"""
+
+__docformat__ = 'restructuredtext'
+
+import os
+import sys
+import string
+import time
+import traceback
+import collections
+import yaml
+from trapd_exit import cleanup_and_exit
+
+
+prog_name = os.path.basename(__file__)
+
+
+# # # # # # # # # # # # # # # # # # # # # # # # # # # # # #
+# function: get_yaml_cfg
+# # # # # # # # # # # # # # # # # # # # # # # # # # # # # #
+
+
+def read_yaml_config(loc_yaml_conf_file):
+    """
+    Load all sorts of goodies from yaml config file.
+    :Parameters:
+      loc_yaml_conf_file
+        filename including full path to yaml config file
+    :Exceptions:
+      file open
+        this function will throw an exception if unable to open
+        loc_yaml_conf_file (fatal error) or any of the required
+        values are not found in the loc_yaml_conf_file (fatal error)
+    :Keywords:
+      yaml config runtime protocol files dmaap
+    :Variables:
+      yc_transport
+        protocol transport for snmp traps (udp|tcp)
+      yc_ipv4_interface
+        what ipv4 interface to listen for traps on
+      yc_ipv4_port
+        what port to listen for traps on
+      yc_dns_cache_ttl_seconds
+        how many seconds an entry remains in DNS cache prior to refresh
+      yc_runtime_base_dir
+        base directory of dcae_snmptrapd application
+      yc_log_dir
+        log directory of dcae_snmptrapd application
+      yc_data_dir
+        data directory of dcae_snmptrapd application
+      yc_pid_dir
+        directory where running PID file will be written (filename <yc_pid_dir>/<prog_name>.pid)
+      yc_trapd_diag
+        program diagnostic log, auto rotated and archived via python handler
+      yc_raw_traps_log
+        file to write raw trap data to
+      yc_published_traps_dir
+        file to write json formatted trap data for successful publishes (only!)
+      yc_trap_stats_log
+        file to write trap stats (traps per second, by OID, by agent)
+      yc_perm_status_file
+        file to write trap stats (traps per second, by OID, by agent)
+      yc_dmaap_conf
+        file (full path) of yaml config entries referenced at runtime, passed as
+        runtime command argument "-c <yc_dmaap_conf>
+      yc_http_timeout
+        http timeout in seconds for dmaap publish attempt
+      yc_http_retries
+        num of http retries to attempt in response to failed post
+      yc_primary_publisher
+        boolean defining whether local instance is primary (future use)
+      yc_peer_publisher
+        identity of peer publisher in case this one fails (future use)
+      yc_max_traps_between_publish
+        if batching publishes, max number of traps to queue before http post
+      yc_max_milliseconds_between_publish
+        if batching publishes, max number of milliseconds between http post
+        Note:  using the batch feature creates an opportunity for trap loss if
+        traps stop arriving and the process exits (traps in queue will remain
+        there until another trap arrives and kicks of the evaluation of max_traps
+        or max_milliseconds above).
+    """
+
+    # named tuple for values in yaml config file
+    _yaml_config_values_nt = collections.namedtuple('yaml_config_values', ['yc_transport', 'yc_ipv4_port', 'yc_ipv4_interface', 'yc_ipv6_port', 'yc_ipv6_interface', 'yc_dns_cache_ttl_seconds', 'yc_runtime_base_dir', 'yc_log_dir', 'yc_data_dir', 'yc_pid_dir', 'yc_trap_conf', 'yc_trapd_diag',
+                                                                           'yc_raw_traps_log', 'yc_published_traps_dir', 'yc_trap_stats_log', 'yc_perm_status_file', 'yc_dmaap_conf', 'yc_http_timeout', 'yc_http_retries', 'yc_http_secs_between_retries', 'yc_primary_publisher', 'yc_peer_publisher', 'yc_max_traps_between_publish', 'yc_max_milliseconds_between_publish'])
+
+    with open(loc_yaml_conf_file, 'r') as yaml_fd:
+        cfg_data = yaml.load(yaml_fd)
+
+    # ONAP FIXME: split try into per-section except loops below
+    try:
+        # protocol
+        yc_transport = (cfg_data['protocol']['transport'])
+        yc_ipv4_interface = (cfg_data['protocol']['ipv4_interface'])
+        yc_ipv4_port = int(cfg_data['protocol']['ipv4_port'])
+        yc_ipv6_interface = (cfg_data['protocol']['ipv6_interface'])
+        yc_ipv6_port = int(cfg_data['protocol']['ipv6_port'])
+        yc_dns_cache_ttl_seconds = int(
+            cfg_data['protocol']['dns_cache_ttl_seconds'])
+
+        # files and directories
+        yc_runtime_base_dir = (cfg_data['files']['runtime_base_dir'])
+        yc_log_dir = (cfg_data['files']['log_dir'])
+        yc_data_dir = (cfg_data['files']['data_dir'])
+        yc_pid_dir = (cfg_data['files']['pid_dir'])
+        yc_trap_conf = (cfg_data['files']['trap_conf'])
+        yc_trapd_diag = (cfg_data['files']['snmptrapd_diag'])
+        yc_raw_traps_log = (cfg_data['files']['raw_traps_log'])
+        yc_published_traps_dir = (cfg_data['files']['published_traps_dir'])
+        yc_trap_stats_log = (cfg_data['files']['trap_stats_log'])
+        yc_perm_status_file = (cfg_data['files']['perm_status_file'])
+
+        # dmaap
+        yc_dmaap_conf = (cfg_data['dmaap']['dmaap_conf'])
+        yc_http_timeout = (cfg_data['dmaap']['http_timeout'])
+        yc_http_retries = (cfg_data['dmaap']['http_retries'])
+        yc_http_secs_between_retries = (
+            cfg_data['dmaap']['http_secs_between_retries'])
+        yc_primary_publisher = (cfg_data['dmaap']['primary_publisher'])
+        yc_peer_publisher = (cfg_data['dmaap']['peer_publisher'])
+        yc_max_traps_between_publish = (
+            cfg_data['dmaap']['max_traps_between_publish'])
+        yc_max_milliseconds_between_publish = (
+            cfg_data['dmaap']['max_milliseconds_between_publish'])
+
+    except:
+        print("ERROR reading config:    %s" % loc_yaml_conf_file)
+        raise
+        cleanup_and_exit(1, "undefined")
+
+    # print back for confirmation
+    print("Configs read from: %s" % loc_yaml_conf_file)
+    print("    protocol section:")
+    print("        transport: %s" % yc_transport)
+    print("        ipv4_port: %s" % yc_ipv4_port)
+    print("        ipv4_interface: %s" % yc_ipv4_interface)
+    print("        ipv6_port: %s" % yc_ipv6_port)
+    print("        ipv6_interface: %s" % yc_ipv6_interface)
+    print("        dns_cache_ttl_seconds: %s" % yc_dns_cache_ttl_seconds)
+    print("    files section:")
+    print("        runtime_base_dir: %s" % yc_runtime_base_dir)
+    print("        log_dir: %s" % yc_log_dir)
+    print("        data_dir: %s" % yc_data_dir)
+    print("        pid_dir: %s" % yc_pid_dir)
+    print("        trap_conf: %s" % yc_trap_conf)
+    print("        snmptrapd_diag: %s" % yc_trapd_diag)
+    print("        raw_traps_log: %s" % yc_raw_traps_log)
+    print("        published_traps_dir: %s" % yc_published_traps_dir)
+    print("        trap_stats_log: %s" % yc_trap_stats_log)
+    print("        perm_status_file: %s" % yc_perm_status_file)
+    print("    dmaap section:")
+    print("        dmaap_config_file: %s" % yc_dmaap_conf)
+    print("        http_timeout: %s" % yc_http_timeout)
+    print("        http_retries: %s" % yc_http_retries)
+    print("        http_secs_between_retries: %s" %
+          yc_http_secs_between_retries)
+    print("        primary_publisher: %s" % yc_primary_publisher)
+    print("        peer_publisher: %s" % yc_peer_publisher)
+    print("        max_traps_between_publish: %s" %
+          yc_max_traps_between_publish)
+    print("        max_milliseconds_between_publish: %s" %
+          yc_max_milliseconds_between_publish)
+
+    _yaml_config_values = _yaml_config_values_nt(yc_transport=yc_transport, yc_ipv4_port=yc_ipv4_port, yc_ipv4_interface=yc_ipv4_interface, yc_ipv6_port=yc_ipv6_port, yc_ipv6_interface=yc_ipv6_interface, yc_dns_cache_ttl_seconds=yc_dns_cache_ttl_seconds, yc_runtime_base_dir=yc_runtime_base_dir, yc_log_dir=yc_log_dir, yc_data_dir=yc_data_dir, yc_pid_dir=yc_pid_dir, yc_trap_conf=yc_trap_conf, yc_trapd_diag=yc_trapd_diag, yc_raw_traps_log=yc_raw_traps_log, yc_published_traps_dir=yc_published_traps_dir,
+                                                 yc_trap_stats_log=yc_trap_stats_log, yc_perm_status_file=yc_perm_status_file, yc_dmaap_conf=yc_dmaap_conf, yc_http_timeout=yc_http_timeout, yc_http_retries=yc_http_retries, yc_http_secs_between_retries=yc_http_secs_between_retries, yc_primary_publisher=yc_primary_publisher, yc_peer_publisher=yc_peer_publisher, yc_max_traps_between_publish=yc_max_traps_between_publish, yc_max_milliseconds_between_publish=yc_max_milliseconds_between_publish)
+
+    return _yaml_config_values