diff options
author | Yun Huang <yun.huang@windriver.com> | 2018-07-04 18:25:03 +0800 |
---|---|---|
committer | Yun Huang <yun.huang@windriver.com> | 2018-07-04 18:26:36 +0800 |
commit | dca44c30fc4d5ecb3389dc22bbecc9bdc0d92316 (patch) | |
tree | 54ed2b02d1023e603841c5f723fc00a227342c81 | |
parent | a159918d3815eb2e9fc1039bc151b7fb0854d41b (diff) |
correct the timestamp granularity
Change-Id: Idd4bfc58e09d48ffb8230ae7e8639f0dd078a724
Issue-ID: MULTICLOUD-236
Signed-off-by: Yun Huang <yun.huang@windriver.com>
-rw-r--r-- | ocata/ocata/vesagent/event_domain/fault_vm.py | 17 |
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 |