fork download
  1. # import logging
  2. # logger = logging.getLogger()
  3.  
  4. # def _update_field(field, key, dict_to_update, dict_from_update):
  5. # if key not in dict_from_update:
  6. # return
  7. # dict_to_update[field] = dict_from_update[key]['value']
  8. # return dict_to_update
  9.  
  10. # # normalized_message_dict = dict()
  11. # detailsObj = {'rdu_circuit_breaker1/rms_current': {'value':'a'}, 'rdu_circuit_breaker2/rms_current': {'value':'b'}, 'rdu_circuit_breaker3/rms_current': {'value':'c'}, 'rdu_circuit_breaker4/rms_current': {'value':'d'}}
  12.  
  13. # # circuitBreakerMetrices_list = list()
  14. # # for circuitBreaker in ('rdu_circuit_breaker1', 'rdu_circuit_breaker2', 'rdu_circuit_breaker3', 'rdu_circuit_breaker4', 'rdu_circuit_breaker5', 'rdu_circuit_breaker6'):
  15. # circuitBreakerMetrices_dict = dict()
  16. # # try:
  17. # # value = detailsObj[circuitBreaker + '/' + 'rms_current']
  18. # # except KeyError as e:
  19. # # logger.exception('Failed to fetch key: {0}'.format(circuitBreaker + '/' + 'rms_current'))
  20. # a = _update_field('rms_current', 'rdu_circuit_breaker1' + '/' + 'rms_current', circuitBreakerMetrices_dict, detailsObj)
  21. # print(a)
  22. # # circuitBreakerMetrices_list.append(circuitBreakerMetrices_dict)
  23. # # normalized_message_dict['circuitBreakerMetrices'] = circuitBreakerMetrices_list
  24.  
  25. # # print(normalized_message_dict)
  26. # # # if circuitBreaker + '/' + 'rms_current' in detailsObj:
  27. # # # print("haha")
  28.  
  29. detailsObj = {'rms_voltage': {'value': 100, 'time': 1573808692}, 'rms_current': {'value': 100, 'time': 1573808692}}
  30. a = int((detailsObj[list(detailsObj.keys())[-1]]['time']) * 1000)
  31. print(a)
Success #stdin #stdout 0.02s 9124KB
stdin
Standard input is empty
stdout
1573808692000