def pushFrame()

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()