summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rwxr-xr-x[-rw-r--r--]miss_htbt_service/htbtworker.py12
1 files changed, 9 insertions, 3 deletions
diff --git a/miss_htbt_service/htbtworker.py b/miss_htbt_service/htbtworker.py
index 347dbd6..6123386 100644..100755
--- a/miss_htbt_service/htbtworker.py
+++ b/miss_htbt_service/htbtworker.py
@@ -85,13 +85,18 @@ def periodic_event():
# Process the DMaaP input message retreived
for line in jlist:
print("Line:"+line)
- jobj = json.loads(line)
+ try:
+ jobj = json.loads(line)
+ except ValueError:
+ print('Decoding JSON has failed')
+ continue
#print(jobj)
- if( nfc != jobj['event']['commonEventHeader']['nfNamingCode']) :
- continue
srcid = (jobj['event']['commonEventHeader']['sourceId'])
lastepo = (jobj['event']['commonEventHeader']['lastEpochMicrosec'])
seqnum = (jobj['event']['commonEventHeader']['sequence'])
+ nfcode = (jobj['event']['commonEventHeader']['nfNamingCode'])
+ if( nfcode and nfc != nfcode):
+ continue
if( srcid in hearttrack ):
tdiff = lastepo - hearttrack[srcid]
sdiff = seqnum - heartstate[srcid]
@@ -197,6 +202,7 @@ def main(args):
cl_loop = args[7]
print ("Message router url %s " % mr_url)
print ("Policy router url %s " % pol_url)
+ print ("VNF %s " % nfc)
print ("Interval %s " % intvl)
if( cl_loop != "internal_test") :
#intvl = 60 # every second