Video

Video on Internet for Camera pi P2P

receive server

# import imagezmq from parent directoryimport syssys.path.insert(0, '../imagezmq') # imagezmq.py is in ../imagezmq
import numpy as npimport cv2import imagezmq
image_hub = imagezmq.ImageHub()while True: # show streamed images until Ctrl-C rpi_name, jpg_buffer = image_hub.recv_jpg() image = cv2.imdecode(np.fromstring(jpg_buffer, dtype='uint8'), -1) # see opencv docs for info on -1 parameter cv2.imshow(rpi_name, image) # 1 window for each RPi cv2.waitKey(1) image_hub.send_reply(b'OK')

send client

# import imagezmq from parent directoryimport syssys.path.insert(0, '../imagezmq') # imagezmq.py is in ../imagezmq
import socketimport timeimport cv2#from imutils.video import VideoStreamimport imagezmq
# use either of the formats below to specifiy address of display computer# sender = imagezmq.ImageSender(connect_to='tcp://jeff-macbook:5555')sender = imagezmq.ImageSender(connect_to='tcp://192.168.1.19:5555')
rpi_name = socket.gethostname() # send RPi hostname with each image#picam = VideoStream(usePiCamera=True).start()picam = cv2.VideoCapture(0)
time.sleep(2.0) # allow camera sensor to warm upjpeg_quality = 95 # 0 to 100, higher is better quality, 95 is cv2 defaultwhile True: # send images as stream until Ctrl-C ret, image = picam.read() ret_code, jpg_buffer = cv2.imencode( ".jpg", image, [int(cv2.IMWRITE_JPEG_QUALITY), jpeg_quality]) sender.send_jpg(rpi_name, jpg_buffer)

timing_receive_jpg_buf.py -- receive and display images, then print FPS stats

import syssys.path.insert(0, '../imagezmq') # imagezmq.py is in ../imagezmq
import timeimport tracebackimport numpy as npimport cv2from collections import defaultdictfrom imutils.video import FPSimport imagezmq
# instantiate image_hubimage_hub = imagezmq.ImageHub()
image_count = 0sender_image_counts = defaultdict(int) # dict for counts by senderfirst_image = True
try: while True: # receive images until Ctrl-C is pressed sent_from, jpg_buffer = image_hub.recv_jpg() if first_image: fps = FPS().start() # start FPS timer after first image is received first_image = False image = cv2.imdecode(np.fromstring(jpg_buffer, dtype='uint8'), -1) # see opencv docs for info on -1 parameter fps.update() image_count += 1 # global count of all images received sender_image_counts[sent_from] += 1 # count images for each RPi name cv2.imshow(sent_from, image) # display images 1 window per sent_from cv2.waitKey(1) image_hub.send_reply(b'OK') # REP replyexcept (KeyboardInterrupt, SystemExit): pass # Ctrl-C was pressed to end program; FPS stats computed belowexcept Exception as ex: print('Python error with no Exception handler:') print('Traceback error:', ex) traceback.print_exc()finally: # stop the timer and display FPS information print() print('Test Program: ', __file__) print('Total Number of Images received: {:,g}'.format(image_count)) if first_image: # never got images from any RPi sys.exit() fps.stop() print('Number of Images received from each RPi:') for RPi in sender_image_counts: print(' ', RPi, ': {:,g}'.format(sender_image_counts[RPi])) compressed_size = len(jpg_buffer) print('Size of last jpg buffer received: {:,g} bytes'.format(compressed_size)) image_size = image.shape print('Size of last image received: ', image_size) uncompressed_size = 1 for dimension in image_size: uncompressed_size *= dimension print(' = {:,g} bytes'.format(uncompressed_size)) print('Compression ratio: {:.2f}'.format(compressed_size / uncompressed_size)) print('Elasped time: {:,.2f} seconds'.format(fps.elapsed())) print('Approximate FPS: {:.2f}'.format(fps.fps())) cv2.destroyAllWindows() sys.exit()

timing_send_jpg_buf.py -- send PiCamera image stream, compressing images.

# import imagezmq from parent directoryimport syssys.path.insert(0, '../imagezmq') # imagezmq.py is in ../imagezmq
import socketimport timeimport tracebackimport cv2#from imutils.video import VideoStreamimport imagezmq#import RPi.GPIO as GPIO
# use either of the formats below to specifiy address of display computer# sender = imagezmq.ImageSender(connect_to='tcp://jeff-macbook:5555')sender = imagezmq.ImageSender(connect_to='tcp://192.168.1.19:5555')
# optionally, turn on the LED area lighting#use_led = False # set to True or False as needed# optionally, filp the image verticallyflip = False # set to True of False as needed
#if use_led: #GPIO.setmode(GPIO.BCM) #GPIO.setup(18, GPIO.OUT) #GPIO.output(18, True) # turn on LEDs
rpi_name = socket.gethostname() # send RPi hostname with each image#picam = VideoStream(usePiCamera=True).start()picam = cv2.VideoCapture(0)time.sleep(2.0) # allow camera sensor to warm upjpeg_quality = 95 # 0 to 100, higher is better quality, 95 is cv2 defaulttry: while True: # send images as stream until Ctrl-C ret,image = picam.read() if flip: image = cv2.flip(image, -1) ret_code, jpg_buffer = cv2.imencode( ".jpg", image, [int(cv2.IMWRITE_JPEG_QUALITY), jpeg_quality]) sender.send_jpg(rpi_name, jpg_buffer)except (KeyboardInterrupt, SystemExit): pass # Ctrl-C was pressed to end programexcept Exception as ex: print('Python error with no Exception handler:') print('Traceback error:', ex) traceback.print_exc()finally: #if use_led: #GPIO.output(18, False) # turn off LEDs #GPIO.cleanup() # close GPIO channel and release it picam.stop() sys.exit()

Video Streaming Web Server with Flask Example

1. native Video Web Server using camera dowload file

Install Python dependencies: cv2, flask. pip install opencv-python flask
Run "python main.py".
Navigate the browser to the local webpage.

2. main.py Video Web Server modified for video streaming from camera pi

# import imagezmq from parent directoryimport syssys.path.insert(0, '../imagezmq') # imagezmq.py is in ../imagezmq
import numpy as npimport cv2import imagezmq
#############################################from flask import Flask, render_template, Response#from camera import VideoCamera
app = Flask(__name__)
@app.route('/')def index(): return render_template('index.html')
def gen(): while True: # show streamed images until Ctrl-C rpi_name, jpg_buffer = image_hub.recv_jpg() image = cv2.imdecode(np.fromstring(jpg_buffer, dtype='uint8'), -1) cv2.imshow(rpi_name, image) # 1 window for each RPi cv2.waitKey(1) image_hub.send_reply(b'OK') #frame = camera.get_frame() ret, jpeg = cv2.imencode('.jpg', image) frame = jpeg.tobytes() yield (b'--frame\r\n' b'Content-Type: image/jpeg\r\n\r\n' + frame + b'\r\n\r\n')
@app.route('/video_feed')def video_feed(): return Response(gen(), mimetype='multipart/x-mixed-replace; boundary=frame')
if __name__ == '__main__': image_hub = imagezmq.ImageHub() app.run(host='0.0.0.0', port=4500 ,debug=False)

3.main.py Video Web Server modified for video streaming from camera pi row and column download file

# import imagezmq from parent directoryimport syssys.path.insert(0, '../imagezmq') # imagezmq.py is in ../imagezmq

from imutils import build_montagesfrom datetime import datetimeimport numpy as npimport imagezmqimport argparseimport imutilsimport cv2
# construct the argument parser and parse the argumentsap = argparse.ArgumentParser()ap.add_argument("-mW", "--montageW", required=True, type=int, default=2, help="montage frame width")ap.add_argument("-mH", "--montageH", required=True, type=int, default=2, help="montage frame height")args = vars(ap.parse_args())
frameDict = {}
# initialize the dictionary which will contain information regarding# when a device was last active, then store the last time the check# was made was nowlastActive = {}#lastActiveCheck = datetime.now()
# stores the estimated number of Pis, active checking period, and# calculates the duration seconds to wait before making a check to# see if a device was activeESTIMATED_NUM_PIS = 4ACTIVE_CHECK_PERIOD = 10ACTIVE_CHECK_SECONDS = ESTIMATED_NUM_PIS * ACTIVE_CHECK_PERIOD
# assign montage width and height so we can view all incoming frames# in a single "dashboard"mW = args["montageW"]mH = args["montageH"]

#############################################from flask import Flask, render_template, Response#from camera import VideoCamera
app = Flask(__name__)
@app.route('/')def index(): return render_template('index.html')
def gen(): global imageHub imageHub = imagezmq.ImageHub() lastActiveCheck = datetime.now() while True: # show streamed images until Ctrl-C # receive RPi name and frame from the RPi and acknowledge # the receipt (rpiName, frame) = imageHub.recv_image() imageHub.send_reply(b'OK')
# if a device is not in the last active dictionary then it means # that its a newly connected device if rpiName not in lastActive.keys(): print("[INFO] receiving data from {}...".format(rpiName))
# record the last active time for the device from which we just # received a frame lastActive[rpiName] = datetime.now()
# resize the frame to have a maximum width of 400 pixels, then # grab the frame dimensions and construct a blob frame = imutils.resize(frame, width=400) (h, w) = frame.shape[:2] blob = cv2.dnn.blobFromImage(cv2.resize(frame, (300, 300)), 0.007843, (300, 300), 127.5) cv2.putText(frame, rpiName, (10, 25), cv2.FONT_HERSHEY_SIMPLEX, 0.5, (0, 0, 255), 2) frameDict[rpiName] = frame
# build a montage using images in the frame dictionary montages = build_montages(frameDict.values(), (w, h), (mW, mH))
# display the montage(s) on the screen for (i, montage) in enumerate(montages): cv2.imshow("Professor JJ office monitor ({})".format(i), montage)
# detect any kepresses key = cv2.waitKey(1) & 0xFF
# if current time *minus* last time when the active device check # was made is greater than the threshold set then do a check if (datetime.now() - lastActiveCheck).seconds > ACTIVE_CHECK_SECONDS: # loop over all previously active devices for (rpiName, ts) in list(lastActive.items()): # remove the RPi from the last active and frame # dictionaries if the device hasn't been active recently if (datetime.now() - ts).seconds > ACTIVE_CHECK_SECONDS: print("[INFO] lost connection to {}".format(rpiName)) lastActive.pop(rpiName) frameDict.pop(rpiName)
# set the last active check time as current time lastActiveCheck = datetime.now()
# if the `q` key was pressed, break from the loop if key == ord("q"): break
ret, jpeg = cv2.imencode('.jpg', montage) frame = jpeg.tobytes() yield (b'--frame\r\n' b'Content-Type: image/jpeg\r\n\r\n' + frame + b'\r\n\r\n')
@app.route('/video_feed')def video_feed(): return Response(gen(), mimetype='multipart/x-mixed-replace; boundary=frame')
if __name__ == '__main__': app.run(host='0.0.0.0', port=4500 ,debug=True) cv2.destroyAllWindows()

4. Raspberry pi send image client

# import imagezmq from parent directoryimport syssys.path.insert(0, '../imagezmq') # imagezmq.py is in ../imagezmq
import socketimport timeimport cv2from imutils.video import VideoStreamimport imagezmq
# use either of the formats below to specifiy address of display computer# sender = imagezmq.ImageSender(connect_to='tcp://jeff-macbook:5555')sender = imagezmq.ImageSender(connect_to='tcp://192.168.1.17:5555')
rpi_name = socket.gethostname() # send RPi hostname with each imagepicam = VideoStream(usePiCamera=True).start()time.sleep(2.0) # allow camera sensor to warm upwhile True: # send images as stream until Ctrl-C image = picam.read() sender.send_image(rpi_name, image)

OpenCV-Playing-Card-Detector

https://github.com/EdjeElectronics/OpenCV-Playing-Card-Detector

Capture/Webcam to file

ffmpeg -i /dev/video0 -c:v h264_omx -r 10 -vf "drawtext=fontfile=/usr/share/fonts/truetype/freefont/FreeSerif.ttf:text='%{localtime}':x=8:y=8:fontcolor=white: box=1: boxcolor=black" out.mkv

ffmpeg -nostdin -hide_banner -loglevel error -i /dev/video0 -c:v h264_omx -r 10 -vf "drawtext=fontfile=/usr/share/fonts/truetype/freefont/FreeSerif.ttf:text='%{localtime}':x=8:y=8:fontcolor=white: box=1: boxcolor=black" -f rtsp rtsp://localhost:80/live/stream

sudo apt install ffmpeg

ffplay /dev/video0

Google Sites

Report abuse