提交 b0bca549 authored 作者: blu's avatar blu

video uploader: python2 has no support of datetime.timestamp

上级 475eb491
import requests, glob, os, json, socket, datetime import requests, glob, os, json, socket, datetime, time, sys
FILE_PATH = os.getenv('FILE_PATH', '/root/work/opencv-pocs/opencv-motion-detect/') FILE_PATH = os.getenv('FILE_PATH', '/var/data/evsuits/failed_events/')
VIDEO_PATH = os.getenv('VIDEO_PATH', '/root/work/opencv-pocs/opencv-motion-detect/')
API_ADDR=os.getenv('API_ADDR', 'http://evcloudsvc.ilabservice.cloud:10009/upload/evtvideos/') API_ADDR=os.getenv('API_ADDR', 'http://evcloudsvc.ilabservice.cloud:10009/upload/evtvideos/')
#{"fileNames":["slices/237808840_3/20200304_124406.mp4","slices/237808840_3/20200304_124437.mp4"],"params":{"cameraId":"237808840","endTime":"1583297091","headOffset":"0","startTime":"1583297066","tailOffset":"0","type":"event"}} #{"fileNames":["slices/237808840_3/20200304_124406.mp4","slices/237808840_3/20200304_124437.mp4"],"params":{"cameraId":"237808840","endTime":"1583297091","headOffset":"0","startTime":"1583297066","tailOffset":"0","type":"event"}}
...@@ -10,10 +11,11 @@ def upload_file(file): ...@@ -10,10 +11,11 @@ def upload_file(file):
try: try:
with open(file) as jf: with open(file) as jf:
data = json.load(jf) data = json.load(jf)
fileNames = ["{}{}".format(FILE_PATH, x) for x in data["fileNames"]] print("data: ", data, file)
fileNames = ["{}{}".format(VIDEO_PATH, x) for x in data["fileNames"]]
blob = [('files', open(f, 'rb')) for f in fileNames] blob = [('files', open(f, 'rb')) for f in fileNames]
url = API_ADDR + data["params"]["cameraId"] + '?' + '&'.join(["{}={}".format(k,v) for k,v in data["params"].items()]) url = API_ADDR + data["params"]["cameraId"] + '?' + '&'.join(["{}={}".format(k,v) for k,v in data["params"].items()])
r = requests.post(url, files = blob) r = requests.post(url, files = blob, timeout = 60*10)
print(file, fileNames, r.status_code, r.text) print(file, fileNames, r.status_code, r.text)
if(r.status_code == 200 and ('code' in r.json()) and r.json()['code'] == 0): if(r.status_code == 200 and ('code' in r.json()) and r.json()['code'] == 0):
success = True success = True
...@@ -34,9 +36,9 @@ def upload_file(file): ...@@ -34,9 +36,9 @@ def upload_file(file):
success = True success = True
# file io error # file io error
os.remove(file) os.remove(file)
print(e) print("IOError Exception:", e)
except Exception as e: except Exception as e:
print(e) print("General Exception:", e)
return success return success
...@@ -53,7 +55,7 @@ if __name__ == "__main__": ...@@ -53,7 +55,7 @@ if __name__ == "__main__":
s.bind(('localhost', 45431)) s.bind(('localhost', 45431))
files = list_files(FILE_PATH) files = list_files(FILE_PATH)
for f in files: for f in files:
now = datetime.datetime.now().timestamp() now = time.mktime(datetime.datetime.now().timetuple())
mts = os.path.getmtime(f) mts = os.path.getmtime(f)
# defer those files may still in recording # defer those files may still in recording
if now - mts < 35: if now - mts < 35:
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论