修改utc时间

Controller/AWS/KVSController.py

@@ -275,9 +275,8 @@ class KVSView(View):
         end_time = request_dict.get('endTime', None)
         if not all([serial_number, start_time, end_time]):
             return response.json(444)
-        utc_timezone = pytz.timezone("UTC")
-        start_time = datetime.datetime.fromtimestamp(int(start_time)).astimezone(utc_timezone)
-        end_time = datetime.datetime.fromtimestamp(int(end_time)).astimezone(utc_timezone)
+        start_time = datetime.datetime.fromtimestamp(int(start_time)).astimezone(datetime.timezone.utc)
+        end_time = datetime.datetime.fromtimestamp(int(end_time)).astimezone(datetime.timezone.utc)
         try:
             # kvs_qs = KVS.objects.filter(stream_name=serial_number)
             # if not kvs_qs.exists():
@@ -316,9 +315,8 @@ class KVSView(View):
             return response.json(444)
         page = int(page)
         size = int(size)
-        utc_timezone = pytz.timezone("UTC")
-        start_time = datetime.datetime.fromtimestamp(int(start_time)).astimezone(utc_timezone)
-        end_time = datetime.datetime.fromtimestamp(int(end_time)).astimezone(utc_timezone)
+        start_time = datetime.datetime.fromtimestamp(int(start_time)).astimezone(datetime.timezone.utc)
+        end_time = datetime.datetime.fromtimestamp(int(end_time)).astimezone(datetime.timezone.utc)
         try:
             # kvs_qs = KVS.objects.filter(stream_name=serial_number)
             # if not kvs_qs.exists():
@@ -340,7 +338,7 @@ class KVSView(View):
             stream_list = kinesis_fragments_obj.get_list_fragments(serial_number, start_time, end_time)[
                           (page - 1) * size:page * size]
             for item in stream_list:
-                temp_start_time = item['startTime'].astimezone(utc_timezone)
+                temp_start_time = item['startTime'].astimezone(datetime.timezone.utc)
                 temp_end_time = temp_start_time + datetime.timedelta(seconds=300)
                 item['image'] = kinesis_images_obj.get_images(serial_number, temp_start_time, temp_end_time)
                 item['startTime'] = int(time.mktime(item['startTime'].timetuple()))