motionDetectionPiMultiProcessing_COM_LiveFeed.py 文件源码

def cameraReader(cam_writer_frames_Queue, cam_liveWeb_frame_Queue):

    camera = picamera.PiCamera()
    camera.resolution = (320, 240)
    camera.framerate = FPS
    stream = picamera.array.PiRGBArray(camera)

    while True:

        FRAMES = list()
        t1 = time.time()
        startTime = time.time()
        for c in xrange(FRAMES_PER_CLIP):
            frameTimestamp = time.asctime() + ' ' + time.tzname[0]
            camera.capture(stream, format='bgr', use_video_port=True)
            frame = stream.array
            if cam_liveWeb_frame_Queue.full() == False:
                cam_liveWeb_frame_Queue.put(frame, block=False)
            FRAMES.append((frameTimestamp, frame))
            stream.truncate(0)
        print "Camera Capture", time.time() - t1

        # Sending frame to processing process
        cam_writer_frames_Queue.put((startTime, FRAMES))
        del FRAMES

    return
    camera.close()