1
1
import json
2
- from datetime import datetime , timedelta
2
+ from datetime import datetime , timedelta , timezone
3
3
from dateutil .relativedelta import *
4
4
5
5
from webex_constants import (
@@ -57,19 +57,19 @@ def collect_events(helper, ew):
57
57
else :
58
58
# shift 1 second to avoid duplicate
59
59
start_time = (
60
- datetime .strptime (timestamp , "%Y-%m-%dT%H:%M:%SZ " ) + timedelta (seconds = 1 )
61
- ).strftime ("%Y-%m-%dT%H:%M:%SZ" )
60
+ datetime .strptime (timestamp , "%Y-%m-%dT%H:%M:%S.%fZ " ) + timedelta (seconds = 1 )
61
+ ).strftime ("%Y-%m-%dT%H:%M:%S.%f" )[: - 3 ] + 'Z'
62
62
63
63
# set up end time
64
- now = datetime .utcnow ( )
64
+ now = datetime .now ( timezone . utc )
65
65
66
- if opt_end_time and datetime .strptime (opt_end_time , "%Y-%m-%dT%H:%M:%SZ" ) < now :
66
+ if opt_end_time and datetime .strptime (opt_end_time , "%Y-%m-%dT%H:%M:%S.%fZ" ). replace ( tzinfo = timezone . utc ) < now :
67
67
end_time = opt_end_time
68
68
else :
69
- end_time = (now - timedelta (minutes = 5 )).strftime ("%Y-%m-%dT%H:%M:%SZ" )
69
+ end_time = (now - timedelta (minutes = 5 )).strftime ("%Y-%m-%dT%H:%M:%S.%f" )[: - 3 ] + 'Z'
70
70
71
71
# compare if start_time ?> end_time, if so, break
72
- if datetime .strptime (start_time , "%Y-%m-%dT%H:%M:%SZ " ) > datetime .strptime (end_time , "%Y-%m-%dT%H:%M:%SZ " ):
72
+ if datetime .strptime (start_time , "%Y-%m-%dT%H:%M:%S.%fZ " ) > datetime .strptime (end_time , "%Y-%m-%dT%H:%M:%S.%fZ " ):
73
73
helper .log_info (
74
74
"[-] Finished ingestion for time range {start_time} - {end_time}" .format (
75
75
start_time = start_time , end_time = end_time
@@ -89,14 +89,15 @@ def collect_events(helper, ew):
89
89
expiration_checkpoint_key = _TOKEN_EXPIRES_CHECKPOINT_KEY .format (
90
90
account_name = account_name
91
91
)
92
+
92
93
access_token_expired_time = helper .get_check_point (expiration_checkpoint_key )
93
94
94
- now = datetime .utcnow ( )
95
+ now = datetime .now ( timezone . utc )
95
96
96
97
# update the access token if it expired
97
98
if (
98
99
not access_token_expired_time
99
- or datetime .strptime (access_token_expired_time , "%m/%d/%Y %H:%M:%S" ) < now
100
+ or datetime .strptime (access_token_expired_time , "%m/%d/%Y %H:%M:%S" ). replace ( tzinfo = timezone . utc ) < now
100
101
):
101
102
102
103
helper .log_debug (
0 commit comments