in frame-extraction/fextractor.py [0:0]
def pushFrame(self):
cap = cv2.VideoCapture(self.cameraSettings.videoStreamUrl)
ret, frame = cap.read()
if ret:
hasFrame, imageBytes = cv2.imencode(".jpg", frame)
if hasFrame:
session = boto3.session.Session()
s3Client = session.client('s3')
now = datetime.now()
objectName = "images/{}/{}/{}_{}_{}_{:0=2d}_{:0=2d}_{:0=2d}_{:0=2d}_{:0=2d}.jpg".format(self.cameraSettings.area, self.cameraSettings.subarea,
self.cameraSettings.area, self.cameraSettings.subarea,
now.year, now.month, now.day, now.hour, now.minute, now.second)
print("Uploading:\t{}".format(objectName))
if(self.cameraSettings.isFisheye):
md = {"isfisheye" : "1", "camera_model": "0000"}
else:
md = {"isfisheye" : "0", "camera_model": "0000"}
s3Client.put_object(Body=imageBytes.tobytes(), Bucket=self.cameraSettings.s3Bucket, Key=objectName, ContentType="image/jpg", Metadata=md)
print("Uploaded:\t{}".format(objectName))
cap.release()