summaryrefslogtreecommitdiffstats
path: root/miss_htbt_service/misshtbtd.py
diff options
context:
space:
mode:
Diffstat (limited to 'miss_htbt_service/misshtbtd.py')
-rw-r--r--miss_htbt_service/misshtbtd.py17
1 files changed, 0 insertions, 17 deletions
diff --git a/miss_htbt_service/misshtbtd.py b/miss_htbt_service/misshtbtd.py
index 12d439a..1808439 100644
--- a/miss_htbt_service/misshtbtd.py
+++ b/miss_htbt_service/misshtbtd.py
@@ -71,14 +71,6 @@ def create_database(update_db, jsfile, ip_address, port_num, user_name, password
cur.execute(query_value)
else:
_logger.info("MSHBD:Database already exists")
- '''
- con = None
- con = connect(user=user_name, host = ip_address, password=password)
- database_name = db_name
- con.autocommit = True
- cur = con.cursor()
- cur.execute('CREATE DATABASE %s IF NOT EXISTS %s' %(database_name,database_name))
- '''
cur.close()
con.close()
except(Exception) as err:
@@ -86,12 +78,6 @@ def create_database(update_db, jsfile, ip_address, port_num, user_name, password
_logger.error(msg)
-# def get_pol_and_mr_urls(jsfile, pol_url, mr_url):
-# with open(jsfile, 'r') as outfile:
-# cfg = json.load(outfile)
-# mr_url = str(cfg['streams_subscribes']['ves-heartbeat']['dmaap_info']['topic_url'])
-# pol_url = str(cfg['streams_publishes']['dcae_cl_out']['dmaap_info']['topic_url'])
-
def read_hb_common(user_name, password, ip_address, port_num, db_name):
envPytest = os.getenv('pytest', "")
if (envPytest == 'test'):
@@ -158,7 +144,6 @@ def create_update_vnf_table_1(jsfile, update_db, connection_db):
vnf_list = [item[0] for item in cur.fetchall()]
for vnf in (jhbcfg['vnfs']):
nfc = vnf['eventName']
- # _logger.error("MSHBT:",nfc)
validity_flag = 1
source_name_count = 0
missed = vnf['heartbeatcountmissed']
@@ -177,7 +162,6 @@ def create_update_vnf_table_1(jsfile, update_db, connection_db):
query_value = "UPDATE vnf_table_1 SET HEARTBEAT_MISSED_COUNT='%d',HEARTBEAT_INTERVAL='%d', CLOSED_CONTROL_LOOP_NAME='%s',POLICY_VERSION='%s',POLICY_NAME='%s', POLICY_SCOPE='%s',TARGET_TYPE='%s', TARGET='%s',VERSION='%s',VALIDITY_FLAG='%d' where EVENT_NAME='%s'" % (missed, intvl, clloop, policyVersion, policyName, policyScope, target_type, target, version, validity_flag, nfc)
if (envPytest != 'test'):
cur.execute(query_value)
- # heartbeat.commit_and_close_db(connection_db)
if (envPytest != 'test'):
cur.close()
_logger.info("MSHBT:Updated vnf_table_1 as per the json configuration file")
@@ -261,7 +245,6 @@ def read_hb_properties(jsfile):
def fetch_json_file():
if get_cbs_config():
- # current_runtime_config_file_name = tds.c_config['files.runtime_base_dir'] + "../etc/download.json"
envPytest = os.getenv('pytest', "")
if (envPytest == 'test'):
current_runtime_config_file_name = "/tmp/opt/app/miss_htbt_service/etc/config.json"