summaryrefslogtreecommitdiffstats
path: root/ocata
diff options
context:
space:
mode:
authorYun Huang <yun.huang@windriver.com>2018-07-04 18:25:03 +0800
committerYun Huang <yun.huang@windriver.com>2018-07-04 18:26:36 +0800
commitdca44c30fc4d5ecb3389dc22bbecc9bdc0d92316 (patch)
tree54ed2b02d1023e603841c5f723fc00a227342c81 /ocata
parenta159918d3815eb2e9fc1039bc151b7fb0854d41b (diff)
correct the timestamp granularity
Change-Id: Idd4bfc58e09d48ffb8230ae7e8639f0dd078a724 Issue-ID: MULTICLOUD-236 Signed-off-by: Yun Huang <yun.huang@windriver.com>
Diffstat (limited to 'ocata')
-rw-r--r--ocata/ocata/vesagent/event_domain/fault_vm.py17
1 files changed, 14 insertions, 3 deletions
diff --git a/ocata/ocata/vesagent/event_domain/fault_vm.py b/ocata/ocata/vesagent/event_domain/fault_vm.py
index c2bab806..7180e1c7 100644
--- a/ocata/ocata/vesagent/event_domain/fault_vm.py
+++ b/ocata/ocata/vesagent/event_domain/fault_vm.py
@@ -23,6 +23,17 @@ from django.conf import settings
from ocata.vesagent.vespublish import publishAnyEventToVES
from common.utils.restcall import _call_req
+import datetime
+import time
+def get_epoch_now_usecond():
+ '''
+ get epoch timestamp of this moment in usecond
+ :return:
+ '''
+ now_time = datetime.datetime.now()
+ epoch_time_sec = time.mktime(now_time.timetuple())
+ return int(epoch_time_sec * 1e6 + now_time.microsecond)
+
logger = logging.getLogger(__name__)
### build backlog with domain:"fault", type:"vm"
@@ -202,8 +213,8 @@ def data2event_fault_vm(oneBacklog, last_event, vm_data):
reportingEntityName = ''
sequence = 0
- startEpochMicrosec = int(time.time())
- lastEpochMicrosec = int(time.time())
+ startEpochMicrosec = get_epoch_now_usecond()
+ lastEpochMicrosec = get_epoch_now_usecond()
eventId = str(uuid.uuid4())
pass
@@ -226,7 +237,7 @@ def data2event_fault_vm(oneBacklog, last_event, vm_data):
sequence = 0
startEpochMicrosec = last_event['event']['commonEventHeader']['startEpochMicrosec']
- lastEpochMicrosec = int(time.time())
+ lastEpochMicrosec = get_epoch_now_usecond()
eventId = last_event['event']['commonEventHeader']['eventId']
pass