summaryrefslogtreecommitdiffstats
path: root/windriver/titanium_cloud
diff options
context:
space:
mode:
Diffstat (limited to 'windriver/titanium_cloud')
-rw-r--r--windriver/titanium_cloud/vesagent/event_domain/fault_vm.py17
1 files changed, 14 insertions, 3 deletions
diff --git a/windriver/titanium_cloud/vesagent/event_domain/fault_vm.py b/windriver/titanium_cloud/vesagent/event_domain/fault_vm.py
index 308ef24c..00738ced 100644
--- a/windriver/titanium_cloud/vesagent/event_domain/fault_vm.py
+++ b/windriver/titanium_cloud/vesagent/event_domain/fault_vm.py
@@ -23,6 +23,17 @@ from django.conf import settings
from titanium_cloud.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