devbox
羊村懒王
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Python 调用海康机器人工业相机_python调用海康工业相机

作者：羊村懒王 | 2024-04-04 09:52:38

赞

踩

python调用海康工业相机

一、前期准备

1、python环境搭建

2、安装MVS软件

3、网上博客参考
1）RTSP（Runtime Stream Protocol）协议方向
（很遗憾，此路不通！！！）
因为我们用的 海康机器人工业相机 MV-CU060-10GM 这款相机，不支持 RTSP 协议。

如下博客适用于 海康威视摄像头，并不适用于 海康工业相机，如果是使用海康威视摄像头的小伙伴可以参考下。

参考博客：海康威视摄像头对接SDK实时预览功能和抓拍功能，懒癌福利，可直接CV

2）Java实现方向
（不能完全满足客户需求，此路不全通！！！）

使用Java目前参考官网的示例，实现了图片抓取，并上传的功能，但是没有实现视频流的实时获取和显示的功能。

如果需求只是获取图片，不要求视频流实时显示，可以通过Java就可以实现。

3）Python实现方向
（目前，网上没有直接能完全满足上述三个需求的，本人通过借鉴、整合，结合Flask框架实现的。）

参考博客如下：
python语言下使用opencv接口cv2.VideoCapture()接口调用海康机器人工业相机 （此篇博文可以重点看！！！）

通过python调用海康威视工业摄像头并进行图像存储，同时使用opencv实时图像显示（数据流问题已解决）

python调用海康工业相机并用opencv显示（整体实现）（此篇博文可以重点看！！！）

pyQT5 学习使用 笔记 六 pyQt5+opencv 显示海康GIGE相机动态视频流 (该方式虽然实现了视频的实时显示，但是，无法被给前端直接调用)

web实时显示摄像头图像（python） （此篇博文可以重点看！！！）

4）Flask 的相关教程和博客
https://www.w3cschool.cn/flask/
https://dormousehole.readthedocs.io/en/latest/
https://blog.csdn.net/weixin_44239541/article/details/89390139
https://zhuanlan.zhihu.com/p/104273184
https://blog.csdn.net/tulan_xiaoxin/article/details/79132214

二、Python 代码实现

1、测试代码

1）抓取图片测试代码

前提条件：将 *C:\Program Files (x86)\MVS\Development\Samples\Python* 目录下的 MvImport 目录，copy到自己的工程目录下，创建测试文件 TestGrabImage.py

代码如下：

  1. # -- coding: utf-8 --
  2. import cv2
  3. import sys
  4. import copy
  5. import msvcrt
  6. import numpy as np
  7.  
  8. from ctypes import *
  9.  
  10. sys.path.append("./MvImport")
  11. from MvCameraControl_class import *
  12.  
  13. if __name__ == "__main__":
  14.  
  15.     deviceList = MV_CC_DEVICE_INFO_LIST()
  16.     tlayerType = MV_GIGE_DEVICE | MV_USB_DEVICE
  17.  
  18.     # ch:枚举设备 | en:Enum device
  19.     ret = MvCamera.MV_CC_EnumDevices(tlayerType, deviceList)
  20.     if ret != 0:
  21.         print ("enum devices fail! ret[0x%x]" % ret)
  22.         sys.exit()
  23.  
  24.     if deviceList.nDeviceNum == 0:
  25.         print ("find no device!")
  26.         sys.exit()
  27.  
  28.     print ("find %d devices!" % deviceList.nDeviceNum)
  29.  
  30.     for i in range(0, deviceList.nDeviceNum):
  31.         mvcc_dev_info = cast(deviceList.pDeviceInfo[i], POINTER(MV_CC_DEVICE_INFO)).contents
  32.         if mvcc_dev_info.nTLayerType == MV_GIGE_DEVICE:
  33.             print ("\ngige device: [%d]" % i)
  34.             strModeName = ""
  35.             for per in mvcc_dev_info.SpecialInfo.stGigEInfo.chModelName:
  36.                 strModeName = strModeName + chr(per)
  37.             print ("device model name: %s" % strModeName)
  38.  
  39.             nip1 = ((mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0xff000000) >> 24)
  40.             nip2 = ((mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0x00ff0000) >> 16)
  41.             nip3 = ((mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0x0000ff00) >> 8)
  42.             nip4 = (mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0x000000ff)
  43.             print ("current ip: %d.%d.%d.%d\n" % (nip1, nip2, nip3, nip4))
  44.         elif mvcc_dev_info.nTLayerType == MV_USB_DEVICE:
  45.             print ("\nu3v device: [%d]" % i)
  46.             strModeName = ""
  47.             for per in mvcc_dev_info.SpecialInfo.stUsb3VInfo.chModelName:
  48.                 if per == 0:
  49.                     break
  50.                 strModeName = strModeName + chr(per)
  51.             print ("device model name: %s" % strModeName)
  52.  
  53.             strSerialNumber = ""
  54.             for per in mvcc_dev_info.SpecialInfo.stUsb3VInfo.chSerialNumber:
  55.                 if per == 0:
  56.                     break
  57.                 strSerialNumber = strSerialNumber + chr(per)
  58.             print ("user serial number: %s" % strSerialNumber)
  59.  
  60.     nConnectionNum = 0
  61.  
  62.     if int(nConnectionNum) >= deviceList.nDeviceNum:
  63.         print ("intput error!")
  64.         sys.exit()
  65.  
  66.     # ch:创建相机实例 | en:Creat Camera Object
  67.     cam = MvCamera()
  68.  
  69.     # ch:选择设备并创建句柄 | en:Select device and create handle
  70.     stDeviceList = cast(deviceList.pDeviceInfo[int(nConnectionNum)], POINTER(MV_CC_DEVICE_INFO)).contents
  71.  
  72.     ret = cam.MV_CC_CreateHandle(stDeviceList)
  73.     if ret != 0:
  74.         print ("create handle fail! ret[0x%x]" % ret)
  75.         sys.exit()
  76.  
  77.     # ch:打开设备 | en:Open device
  78.     ret = cam.MV_CC_OpenDevice(MV_ACCESS_Exclusive, 0)
  79.     if ret != 0:
  80.         print ("open device fail! ret[0x%x]" % ret)
  81.         sys.exit()
  82.  
  83.     # ch:探测网络最佳包大小(只对GigE相机有效) | en:Detection network optimal package size(It only works for the GigE camera)
  84.     if stDeviceList.nTLayerType == MV_GIGE_DEVICE:
  85.         nPacketSize = cam.MV_CC_GetOptimalPacketSize()
  86.         if int(nPacketSize) > 0:
  87.             ret = cam.MV_CC_SetIntValue("GevSCPSPacketSize", nPacketSize)
  88.             if ret != 0:
  89.                 print ("Warning: Set Packet Size fail! ret[0x%x]" % ret)
  90.         else:
  91.             print ("Warning: Get Packet Size fail! ret[0x%x]" % nPacketSize)
  92.  
  93.     # ch:设置触发模式为off | en:Set trigger mode as off
  94.     ret = cam.MV_CC_SetEnumValue("TriggerMode", MV_TRIGGER_MODE_OFF)
  95.     if ret != 0:
  96.         print ("set trigger mode fail! ret[0x%x]" % ret)
  97.         sys.exit()
  98.  
  99.     # ch:获取数据包大小 | en:Get payload size
  100.     stParam = MVCC_INTVALUE()
  101.     memset(byref(stParam), 0, sizeof(MVCC_INTVALUE))
  102.  
  103.     ret = cam.MV_CC_GetIntValue("PayloadSize", stParam)
  104.     if ret != 0:
  105.         print ("get payload size fail! ret[0x%x]" % ret)
  106.         sys.exit()
  107.         
  108.     nPayloadSize = stParam.nCurValue
  109.  
  110.     # ch:开始取流 | en:Start grab image
  111.     ret = cam.MV_CC_StartGrabbing()
  112.     if ret != 0:
  113.         print ("start grabbing fail! ret[0x%x]" % ret)
  114.         sys.exit()
  115.  
  116.     stDeviceList = MV_FRAME_OUT_INFO_EX()
  117.     memset(byref(stDeviceList), 0, sizeof(stDeviceList))
  118.     data_buf = (c_ubyte * nPayloadSize)()
  119.  
  120.     ret = cam.MV_CC_GetOneFrameTimeout(byref(data_buf), nPayloadSize, stDeviceList, 1000)
  121.     if ret == 0:
  122.         print ("get one frame: Width[%d], Height[%d], nFrameNum[%d]" % (stDeviceList.nWidth, stDeviceList.nHeight, stDeviceList.nFrameNum))
  123.  
  124.         nRGBSize = stDeviceList.nWidth * stDeviceList.nHeight * 3
  125.         stConvertParam=MV_SAVE_IMAGE_PARAM_EX()
  126.         stConvertParam.nWidth = stDeviceList.nWidth
  127.         stConvertParam.nHeight = stDeviceList.nHeight
  128.         stConvertParam.pData = data_buf
  129.         stConvertParam.nDataLen = stDeviceList.nFrameLen
  130.         stConvertParam.enPixelType = stDeviceList.enPixelType
  131.         stConvertParam.nImageLen = stConvertParam.nDataLen
  132.         stConvertParam.nJpgQuality = 70
  133.         stConvertParam.enImageType = MV_Image_Jpeg
  134.         stConvertParam.pImageBuffer = (c_ubyte * nRGBSize)()
  135.         stConvertParam.nBufferSize = nRGBSize
  136.         # ret = cam.MV_CC_ConvertPixelType(stConvertParam)
  137.         print(stConvertParam.nImageLen)
  138.         ret = cam.MV_CC_SaveImageEx2(stConvertParam)
  139.         if ret != 0:
  140.             print ("convert pixel fail ! ret[0x%x]" % ret)
  141.             del data_buf
  142.             sys.exit()
  143.         file_path = "AfterConvert_RGB2.jpg"
  144.         file_open = open(file_path.encode('ascii'), 'wb+')
  145.         img_buff = (c_ubyte * stConvertParam.nImageLen)()
  146.         cdll.msvcrt.memcpy(byref(img_buff), stConvertParam.pImageBuffer, stConvertParam.nImageLen)
  147.         file_open.write(img_buff)
  148.     print ("Save Image succeed!")
  149.  
  150.  
  151.     # ch:停止取流 | en:Stop grab image
  152.     ret = cam.MV_CC_StopGrabbing()
  153.     if ret != 0:
  154.         print ("stop grabbing fail! ret[0x%x]" % ret)
  155.         del data_buf
  156.         sys.exit()
  157.  
  158.     # ch:关闭设备 | Close device
  159.     ret = cam.MV_CC_CloseDevice()
  160.     if ret != 0:
  161.         print ("close deivce fail! ret[0x%x]" % ret)
  162.         del data_buf
  163.         sys.exit()
  164.  
  165.     # ch:销毁句柄 | Destroy handle
  166.     ret = cam.MV_CC_DestroyHandle()
  167.     if ret != 0:
  168.         print ("destroy handle fail! ret[0x%x]" % ret)
  169.         del data_buf
  170.         sys.exit()
  171.  
  172.     del data_buf

2）Python+Qt 实现视频流实时显示测试代码
前提条件：将 *C:\Program Files (x86)\MVS\Development\Samples\Python* 目录下的 MvImport 目录，copy到自己的工程目录下，创建测试文件 TestVideoStream.py

代码如下：

  1. # -- coding: utf-8 --
  2. import cv2
  3. from PyQt5 import QtCore, QtGui, QtWidgets
  4. from PyQt5.QtCore import pyqtSignal
  5. from PyQt5.QtGui import *
  6. import numpy as np
  7.  
  8. #from CameraControl_header import MV_CC_DEVICE_INFO_LIST
  9. #from mainWindow import Ui_MainWindow  # 导入创建的GUI类
  10. import sys
  11. import threading
  12. import msvcrt
  13. from ctypes import *
  14.  
  15. sys.path.append("./MvImport")
  16. from MvCameraControl_class import *
  17. from Ui_MainWindow  import *
  18. from CameraParams_header import *
  19.  
  20. class mywindow(QtWidgets.QMainWindow, Ui_MainWindow):
  21.     sendAddDeviceName = pyqtSignal() #定义一个添加设备列表的信号。
  22.     deviceList = MV_CC_DEVICE_INFO_LIST()
  23.     g_bExit = False
  24.     # ch:创建相机实例 | en:Creat Camera Object
  25.     cam = MvCamera()
  26.  
  27.     def connect_and_emit_sendAddDeviceName(self):
  28.         # Connect the sendAddDeviceName signal to a slot.
  29.         self.sendAddDeviceName.connect(self.SelectDevice)
  30.         # Emit the signal.
  31.         self.sendAddDeviceName.emit()
  32.  
  33.     def __init__(self):
  34.         super(mywindow, self).__init__()
  35.         self.setupUi(self)
  36.         self.connect_and_emit_sendAddDeviceName()
  37.         self.butopenCam.clicked.connect(lambda:self.openCam(self.camSelect.currentData()))
  38.         self.butcloseCam.clicked.connect(self.closeCam)
  39.  
  40.         # setting main window geometry
  41.         desktop_geometry = QtWidgets.QApplication.desktop()  # 获取屏幕大小
  42.         main_window_width = desktop_geometry.width()  # 屏幕的宽
  43.         main_window_height = desktop_geometry.height()  # 屏幕的高
  44.         rect = self.geometry()  # 获取窗口界面大小
  45.         window_width = rect.width()  # 窗口界面的宽
  46.         window_height = rect.height()  # 窗口界面的高
  47.         x = (main_window_width - window_width) // 2  # 计算窗口左上角点横坐标
  48.         y = (main_window_height - window_height) // 2  # 计算窗口左上角点纵坐标
  49.         self.setGeometry(x, y, window_width, window_height)  # 设置窗口界面在屏幕上的位置
  50.         # 无边框以及背景透明一般不会在主窗口中用到，一般使用在子窗口中，例如在子窗口中显示gif提示载入信息等等
  51.        # self.setWindowFlags(Qt.FramelessWindowHint)
  52.        # self.setAttribute(Qt.WA_TranslucentBackground)
  53.  
  54.     #打开摄像头。
  55.     def openCam(self,camid):
  56.         self.g_bExit = False
  57.         # ch:选择设备并创建句柄 | en:Select device and create handle
  58.         stDeviceList = cast(self.deviceList.pDeviceInfo[int(camid)], POINTER(MV_CC_DEVICE_INFO)).contents
  59.         ret = self.cam.MV_CC_CreateHandle(stDeviceList)
  60.         if ret != 0:
  61.             print("create handle fail! ret[0x%x]" % ret)
  62.             sys.exit()
  63.         # ch:打开设备 | en:Open device
  64.  
  65.         ret = self.cam.MV_CC_OpenDevice(MV_ACCESS_Exclusive, 0)
  66.         if ret != 0:
  67.             print("open device fail! ret[0x%x]" % ret)
  68.             sys.exit()
  69.  
  70.         # ch:探测网络最佳包大小(只对GigE相机有效) | en:Detection network optimal package size(It only works for the GigE camera)
  71.         if stDeviceList.nTLayerType == MV_GIGE_DEVICE:
  72.             nPacketSize = self.cam.MV_CC_GetOptimalPacketSize()
  73.             if int(nPacketSize) > 0:
  74.                 ret = self.cam.MV_CC_SetIntValue("GevSCPSPacketSize", nPacketSize)
  75.                 if ret != 0:
  76.                     print("Warning: Set Packet Size fail! ret[0x%x]" % ret)
  77.             else:
  78.                 print("Warning: Get Packet Size fail! ret[0x%x]" % nPacketSize)
  79.  
  80.         # ch:设置触发模式为off | en:Set trigger mode as off
  81.         ret = self.cam.MV_CC_SetEnumValue("TriggerMode", MV_TRIGGER_MODE_OFF)
  82.         if ret != 0:
  83.             print("set trigger mode fail! ret[0x%x]" % ret)
  84.             sys.exit()
  85.             # ch:获取数据包大小 | en:Get payload size
  86.         stParam = MVCC_INTVALUE()
  87.         memset(byref(stParam), 0, sizeof(MVCC_INTVALUE))
  88.  
  89.         ret = self.cam.MV_CC_GetIntValue("PayloadSize", stParam)
  90.         if ret != 0:
  91.             print("get payload size fail! ret[0x%x]" % ret)
  92.             sys.exit()
  93.         nPayloadSize = stParam.nCurValue
  94.  
  95.         # ch:开始取流 | en:Start grab image
  96.         ret = self.cam.MV_CC_StartGrabbing()
  97.         if ret != 0:
  98.             print("start grabbing fail! ret[0x%x]" % ret)
  99.             sys.exit()
  100.  
  101.         data_buf = (c_ubyte * nPayloadSize)()
  102.  
  103.         try:
  104.             hThreadHandle = threading.Thread(target=self.work_thread, args=(self.cam, data_buf, nPayloadSize))
  105.             hThreadHandle.start()
  106.         except:
  107.             print("error: unable to start thread")
  108.  
  109.     #关闭相机
  110.     def closeCam(self):
  111.         self.g_bExit=True
  112.         # ch:停止取流 | en:Stop grab image
  113.         ret = self.cam.MV_CC_StopGrabbing()
  114.         if ret != 0:
  115.             print("stop grabbing fail! ret[0x%x]" % ret)
  116.             sys.exit()
  117.  
  118.         # ch:关闭设备 | Close device
  119.         ret = self.cam.MV_CC_CloseDevice()
  120.         if ret != 0:
  121.             print("close deivce fail! ret[0x%x]" % ret)
  122.  
  123.         # ch:销毁句柄 | Destroy handle
  124.         ret = self.cam.MV_CC_DestroyHandle()
  125.         if ret != 0:
  126.             print("destroy handle fail! ret[0x%x]" % ret)
  127.  
  128.     def work_thread(self,cam=0, pData=0, nDataSize=0):
  129.         stFrameInfo = MV_FRAME_OUT_INFO_EX()
  130.         memset(byref(stFrameInfo), 0, sizeof(stFrameInfo))
  131.         while True:
  132.             QIm = np.asarray(pData)  # 将c_ubyte_Array转化成ndarray得到（3686400，）
  133.             QIm = QIm.reshape((2048, 3072, 1))  # 根据自己分辨率进行转化
  134.                 # print(temp)
  135.                 # print(temp.shape)
  136.             QIm = cv2.cvtColor(QIm, cv2.COLOR_BGR2RGB)  # 这一步获取到的颜色不对，因为默认是BRG，要转化成RGB，颜色才正常
  137.             pyrD1=cv2.pyrDown(QIm) #向下取样
  138.             pyrD2 = cv2.pyrDown(pyrD1)  # 向下取样
  139.             image_height, image_width, image_depth = pyrD2.shape  # 读取图像高宽深度
  140.             pyrD3 = QImage(pyrD2, image_width, image_height,  image_width * image_depth,QImage.Format_RGB888)
  141.             self.label.setPixmap(QPixmap.fromImage(pyrD3))
  142.             #cv2.namedWindow("result", cv2.WINDOW_AUTOSIZE)
  143.             #cv2.imshow("result", temp)
  144.             #if cv2.waitKey(1) & 0xFF == ord('q'):
  145.             #    break
  146.  
  147.             ret = cam.MV_CC_GetOneFrameTimeout(pData, nDataSize, stFrameInfo, 1000)
  148.             if ret == 0:
  149.                 print("get one frame: Width[%d], Height[%d], nFrameNum[%d]" % (
  150.                     stFrameInfo.nWidth, stFrameInfo.nHeight, stFrameInfo.nFrameNum))
  151.             else:
  152.                 print("no data[0x%x]" % ret)
  153.             if self.g_bExit == True:
  154.                 del pData
  155.                 break
  156.  
  157.  
  158.     #获得所有相机的列表存入cmbSelectDevice中
  159.     def SelectDevice(self):
  160.         '''选择所有能用的相机到列表中，
  161.              gige相机需要配合 sdk 得到。
  162.         '''
  163.         #得到相机列表
  164.  
  165.         tlayerType = MV_GIGE_DEVICE | MV_USB_DEVICE
  166.     # ch:枚举设备 | en:Enum device
  167.         ret = MvCamera.MV_CC_EnumDevices(tlayerType, self.deviceList)
  168.         if ret != 0:
  169.             print("enum devices fail! ret[0x%x]" % ret)
  170.             sys.exit()
  171.         if self.deviceList.nDeviceNum == 0:
  172.             print("find no device!")
  173.             sys.exit()
  174.  
  175.         print("Find %d devices!" % self.deviceList.nDeviceNum)
  176.         for i in range(0, self.deviceList.nDeviceNum):
  177.             mvcc_dev_info = cast(self.deviceList.pDeviceInfo[i], POINTER(MV_CC_DEVICE_INFO)).contents
  178.             if mvcc_dev_info.nTLayerType == MV_GIGE_DEVICE:
  179.                 print("\ngige device: [%d]" % i)
  180.                 strModeName = ""
  181.                 for per in mvcc_dev_info.SpecialInfo.stGigEInfo.chModelName:
  182.                     strModeName = strModeName + chr(per)
  183.                 print("device model name: %s" % strModeName)
  184.                 self.camSelect.addItem(strModeName,i) #写入设备列表。
  185.  
  186.     def pushbutton_function(self):
  187.         #do some things
  188.         Img=cv2.imread('JP1.JPG') #通过opencv读入一张图片
  189.         image_height, image_width, image_depth=Img.shape #读取图像高宽深度
  190.         QIm=cv2.cvtColor(Img,cv2.COLOR_BGR2RGB)
  191.         QIm=QImage(QIm.data, image_width, image_height,  image_width * image_depth,QImage.Format_RGB888)
  192.         self.label.setPixmap(QPixmap.fromImage(QIm))
  193.  
  194. if __name__ == '__main__':
  195.     app = QtWidgets.QApplication(sys.argv)
  196.     window = mywindow()
  197.     window.show()
  198.     sys.exit(app.exec_())

上述代码中用到的 Ui_MainWindow.py，放到 MvImport 目录下。

代码如下：

  1. # -*- coding: utf-8 -*-
  2.  
  3. # Form implementation generated from reading ui file 'mainWindow.ui'
  4. #
  5. # Created by: PyQt5 UI code generator 5.15.0
  6. #
  7. # WARNING: Any manual changes made to this file will be lost when pyuic5 is
  8. # run again.  Do not edit this file unless you know what you are doing.
  9.  
  10.  
  11. from PyQt5 import QtCore, QtGui, QtWidgets
  12.  
  13.  
  14. class Ui_MainWindow(object):
  15.     def setupUi(self, MainWindow):
  16.         MainWindow.setObjectName("MainWindow")
  17.         MainWindow.resize(589, 530)
  18.         self.centralwidget = QtWidgets.QWidget(MainWindow)
  19.         self.centralwidget.setObjectName("centralwidget")
  20.         self.verticalLayout = QtWidgets.QVBoxLayout(self.centralwidget)
  21.         self.verticalLayout.setObjectName("verticalLayout")
  22.         self.camSelect = QtWidgets.QComboBox(self.centralwidget)
  23.         self.camSelect.setObjectName("camSelect")
  24.         self.verticalLayout.addWidget(self.camSelect)
  25.         self.label = QtWidgets.QLabel(self.centralwidget)
  26.         self.label.setObjectName("label")
  27.         self.verticalLayout.addWidget(self.label)
  28.         self.butopenCam = QtWidgets.QPushButton(self.centralwidget)
  29.         self.butopenCam.setObjectName("butopenCam")
  30.         self.verticalLayout.addWidget(self.butopenCam)
  31.         self.butcloseCam = QtWidgets.QPushButton(self.centralwidget)
  32.         self.butcloseCam.setObjectName("butcloseCam")
  33.         self.verticalLayout.addWidget(self.butcloseCam)
  34.         MainWindow.setCentralWidget(self.centralwidget)
  35.         self.menubar = QtWidgets.QMenuBar(MainWindow)
  36.         self.menubar.setGeometry(QtCore.QRect(0, 0, 589, 23))
  37.         self.menubar.setObjectName("menubar")
  38.         MainWindow.setMenuBar(self.menubar)
  39.         self.statusbar = QtWidgets.QStatusBar(MainWindow)
  40.         self.statusbar.setObjectName("statusbar")
  41.         MainWindow.setStatusBar(self.statusbar)
  42.  
  43.         self.retranslateUi(MainWindow)
  44.         QtCore.QMetaObject.connectSlotsByName(MainWindow)
  45.  
  46.     def retranslateUi(self, MainWindow):
  47.         _translate = QtCore.QCoreApplication.translate
  48.         MainWindow.setWindowTitle(_translate("MainWindow", "MainWindow"))
  49.         self.label.setText(_translate("MainWindow", "TextLabel"))
  50.         self.butopenCam.setText(_translate("MainWindow", "打开相机"))
  51.         self.butcloseCam.setText(_translate("MainWindow", "关闭相机"))

四、使用 Python + OpenCV + Flask 实现，可以满足视频实时获取，并返回通过GET请求返回给前端进行实时显示，也可以抓取图片，保存上传。

1、添加依赖文件
将 *C:\Program Files (x86)\MVS\Development\Samples\Python* 目录下的 MvImport 目录，copy到自己的工程目录下。

2、安装插件 DirectShow
1）进入第三方插件 DirectShow 路径

cd C:\Program Files    (x86)\MVS\Development\ThirdPartyPlatformAdapter\DirectShow\x64\MvDSS2
 


2）安装 DirectShow
使用 管理员权限 运行 InstallDSSvc_x64.bat

在这里插入图片描述

0）index.html

在工程中创建 templates 目录，用于存放 index.hml

<html>
  <head>
  </head>
  <body>
      <h1>拍照预览</h1>
    <img src="{{ url_for('startPreview') }}" width="50%">
  </body>
</html>

1）JsonResponse.py

用于规范返回给前端的数据类型，代码如下：

  1. # -- coding: utf-8 --
  2.  
  3. class JsonResponse(object):
  4.     """
  5.     统一的json返回格式
  6.     """
  7.  
  8.     def __init__(self, code, msg, data):
  9.         self.code = code
  10.         self.msg = msg
  11.         self.data = data
  12.  
  13.     @classmethod
  14.     def success(cls, code=0, msg='success', data=None):
  15.         return cls(code, msg, data)
  16.  
  17.     @classmethod
  18.     def error(cls, code=-1, msg='error', data=None):
  19.         return cls(code, msg, data)
  20.  
  21.     def to_dict(self):
  22.         return {
  23.             "code": self.code,
  24.             "msg": self.msg,
  25.             "data": self.data
  26.         }

2）JsonFlask.py

用于重定义数据返回格式，代码如下：

  1. # -- coding: utf-8 --
  2.  
  3. from flask import Flask, jsonify
  4. from JsonResponse import *
  5.  
  6. class JsonFlask(Flask):
  7.     def make_response(self, rv):
  8.         """视图函数可以直接返回: list、dict、None"""
  9.         if rv is None or isinstance(rv, (list, dict)):
  10.             rv = JsonResponse.success(rv)
  11.  
  12.         if isinstance(rv, JsonResponse):
  13.             rv = jsonify(rv.to_dict())
  14.  
  15.         return super().make_response(rv)

3）HikRobotCamera.py

核心代码文件，实现如下功能：
开始预览视频流、停止预览视频流、获取图片、记录日志等功能。

代码如下

  1. # -- coding: utf-8 --
  2. import cv2
  3. from flask import Flask, render_template, Response
  4.  
  5. import sys
  6. import msvcrt
  7. import base64
  8. import datetime
  9. import logging
  10.  
  11. sys.path.append("./MvImport")
  12. from MvCameraControl_class import *
  13. from JsonResponse import *
  14. from JsonFlask import *
  15.  
  16. logging.basicConfig(level=logging.DEBUG,#控制台打印的日志级别
  17.                     filename='hikrobot.log',
  18.                     filemode='a',##模式，有w和a，w就是写模式，每次都会重新写日志，覆盖之前的日志
  19.                     #a是追加模式，默认如果不写的话，就是追加模式
  20.                     format=
  21.                     '%(asctime)s - %(pathname)s[line:%(lineno)d] - %(levelname)s: %(message)s'
  22.                     #日志格式
  23.                     )
  24.  
  25. # 这里配置一下 template_folder为当前目录，不然可以找不到 index.html
  26. app = JsonFlask(__name__, template_folder='.')
  27.  
  28. # index
  29. @app.route('/')
  30. def index():
  31.     return render_template('./templates/index.html')
  32.  
  33. # 获取码流
  34. def generate(cap):
  35.     # 捕获异常信息
  36.     try:
  37.         while True:
  38.             # 如果是关闭相机，先退出取视频流的循环
  39.             global open
  40.             if (not open):
  41.                 break;
  42.             retgrab = cap.grab()
  43.             if retgrab == True:
  44.                 logging.debug("Grab true")
  45.             ret1, frame = cap.retrieve()
  46.             # print(type(frame))
  47.             if frame is None:
  48.                 logging.error("frame is None")
  49.                 continue
  50.             ret1, jpeg = cv2.imencode('.jpg', frame)
  51.             jpg_frame = jpeg.tobytes()
  52.             yield (b'--frame\r\n'
  53.                 b'Content-Type: image/jpeg\r\n\r\n' + jpg_frame + b'\r\n')
  54.     except Exception as e:
  55.         logging.error("generate error: %s" % str(e))
  56.  
  57.  
  58. # 开始预览
  59. @app.route('/startPreview')
  60. def startPreview():
  61.     logging.info("======================================")
  62.     logging.info("start to preview video stream, current_time: " + str(datetime.datetime.now()))
  63.     # 全局变量，用于控制获取视频流的开关状态
  64.     global open
  65.     open = True
  66.  
  67.     # 全局变量，获取视频连接
  68.     global cap
  69.     cap = cv2.VideoCapture(1)
  70.  
  71.     if False == cap.isOpened():
  72.         logging.error("can't open camera")
  73.         quit()
  74.     else:
  75.         logging.info("start to open camera")
  76.  
  77.     logging.info("open camera ok")
  78.  
  79.     # 分辨率设置 3072*2048（海康机器人工业相机 MV-CU060-10GM）
  80.     cap.set(cv2.CAP_PROP_FRAME_WIDTH, 3072)
  81.     cap.set(cv2.CAP_PROP_FRAME_HEIGHT, 2048)
  82.     # 帧率配置
  83.     cap.set(cv2.CAP_PROP_FPS, 15)   
  84.     return Response(generate(cap), mimetype='multipart/x-mixed-replace;boundary=frame')
  85.  
  86. # 停止预览
  87. @app.route('/stopPreview')
  88. def stopPreview():
  89.     logging.info("======================================")
  90.     logging.info("stop to preview video stream, current_time: " + str(datetime.datetime.now()))
  91.     logging.info("start to close camera")
  92.  
  93.     # 全局变量，用于停止循环
  94.     global open
  95.     open = False
  96.  
  97.     logging.info("release resources start")
  98.     # 全局变量，用于释放相机资源
  99.     try:
  100.         global cap
  101.         cap.release()
  102.         cv2.destroyAllWindows()
  103.     except Exception as e:
  104.         logging.error("stopPreview error: %s" % str(e))
  105.     logging.info("release resources end")
  106.     logging.info("camera closed successfully, current_time: " + str(datetime.datetime.now()))
  107.     logging.info("======================================")
  108.     return "stop to preview"
  109.  
  110.  
  111. @app.route('/openAndSave')
  112. def openAndSave():
  113.     logging.info("======================================")
  114.     logging.info("start to grab image, current_time: " + str(datetime.datetime.now()))
  115.     code = 100000
  116.     msg = "连接相机时发生错误"
  117.     # img_base64 = None
  118.     try:
  119.         deviceList = MV_CC_DEVICE_INFO_LIST()
  120.         tlayerType = MV_GIGE_DEVICE | MV_USB_DEVICE
  121.  
  122.         # ch:枚举设备 | en:Enum device
  123.         ret = MvCamera.MV_CC_EnumDevices(tlayerType, deviceList)
  124.         if ret != 0:
  125.             logging.error("enum devices fail! ret[0x%x]" % ret)
  126.             sys.exit()
  127.  
  128.         if deviceList.nDeviceNum == 0:
  129.             logging.error("find no device!")
  130.             sys.exit()
  131.  
  132.         logging.info("find %d devices!" % deviceList.nDeviceNum)
  133.  
  134.         for i in range(0, deviceList.nDeviceNum):
  135.             mvcc_dev_info = cast(deviceList.pDeviceInfo[i], POINTER(MV_CC_DEVICE_INFO)).contents
  136.             if mvcc_dev_info.nTLayerType == MV_GIGE_DEVICE:
  137.                 logging.info("\ngige device: [%d]" % i)
  138.                 strModeName = ""
  139.                 for per in mvcc_dev_info.SpecialInfo.stGigEInfo.chModelName:
  140.                     strModeName = strModeName + chr(per)
  141.                 logging.info("device model name: %s" % strModeName)
  142.  
  143.                 nip1 = ((mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0xff000000) >> 24)
  144.                 nip2 = ((mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0x00ff0000) >> 16)
  145.                 nip3 = ((mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0x0000ff00) >> 8)
  146.                 nip4 = (mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0x000000ff)
  147.                 logging.info("current ip: %d.%d.%d.%d\n" % (nip1, nip2, nip3, nip4))
  148.             elif mvcc_dev_info.nTLayerType == MV_USB_DEVICE:
  149.                 logging.info("\nu3v device: [%d]" % i)
  150.                 strModeName = ""
  151.                 for per in mvcc_dev_info.SpecialInfo.stUsb3VInfo.chModelName:
  152.                     if per == 0:
  153.                         break
  154.                     strModeName = strModeName + chr(per)
  155.                 logging.info("device model name: %s" % strModeName)
  156.  
  157.                 strSerialNumber = ""
  158.                 for per in mvcc_dev_info.SpecialInfo.stUsb3VInfo.chSerialNumber:
  159.                     if per == 0:
  160.                         break
  161.                     strSerialNumber = strSerialNumber + chr(per)
  162.                 logging.info("user serial number: %s" % strSerialNumber)
  163.  
  164.         nConnectionNum = 0
  165.  
  166.         if int(nConnectionNum) >= deviceList.nDeviceNum:
  167.             logging.error("intput error!")
  168.             sys.exit()
  169.  
  170.         # ch:创建相机实例 | en:Creat Camera Object
  171.         cam = MvCamera()
  172.  
  173.         # ch:选择设备并创建句柄 | en:Select device and create handle
  174.         stDeviceList = cast(deviceList.pDeviceInfo[int(nConnectionNum)], POINTER(MV_CC_DEVICE_INFO)).contents
  175.  
  176.         ret = cam.MV_CC_CreateHandle(stDeviceList)
  177.         if ret != 0:
  178.             logging.error("create handle fail! ret[0x%x]" % ret)
  179.             sys.exit()
  180.  
  181.         # ch:打开设备 | en:Open device
  182.         ret = cam.MV_CC_OpenDevice(MV_ACCESS_Exclusive, 0)
  183.         if ret != 0:
  184.             logging.error("open device fail! ret[0x%x]" % ret)
  185.             sys.exit()
  186.  
  187.         # ch:探测网络最佳包大小(只对GigE相机有效) | en:Detection network optimal package size(It only works for the GigE camera)
  188.         if stDeviceList.nTLayerType == MV_GIGE_DEVICE:
  189.             nPacketSize = cam.MV_CC_GetOptimalPacketSize()
  190.             if int(nPacketSize) > 0:
  191.                 ret = cam.MV_CC_SetIntValue("GevSCPSPacketSize", nPacketSize)
  192.                 if ret != 0:
  193.                     logging.warn("Warning: Set Packet Size fail! ret[0x%x]" % ret)
  194.             else:
  195.                 logging.warn("Warning: Get Packet Size fail! ret[0x%x]" % nPacketSize)
  196.  
  197.         # ch:设置触发模式为off | en:Set trigger mode as off
  198.         ret = cam.MV_CC_SetEnumValue("TriggerMode", MV_TRIGGER_MODE_OFF)
  199.         if ret != 0:
  200.             logging.error("set trigger mode fail! ret[0x%x]" % ret)
  201.             sys.exit()
  202.  
  203.         # ch:获取数据包大小 | en:Get payload size
  204.         stParam = MVCC_INTVALUE()
  205.         memset(byref(stParam), 0, sizeof(MVCC_INTVALUE))
  206.  
  207.         ret = cam.MV_CC_GetIntValue("PayloadSize", stParam)
  208.         if ret != 0:
  209.             logging.error("get payload size fail! ret[0x%x]" % ret)
  210.             sys.exit()
  211.             
  212.         nPayloadSize = stParam.nCurValue
  213.  
  214.         # ch:开始取流 | en:Start grab image
  215.         ret = cam.MV_CC_StartGrabbing()
  216.         if ret != 0:
  217.             logging.error("start grabbing fail! ret[0x%x]" % ret)
  218.             sys.exit()
  219.  
  220.         stDeviceList = MV_FRAME_OUT_INFO_EX()
  221.         memset(byref(stDeviceList), 0, sizeof(stDeviceList))
  222.         data_buf = (c_ubyte * nPayloadSize)()
  223.         
  224.         ret = cam.MV_CC_GetOneFrameTimeout(byref(data_buf), nPayloadSize, stDeviceList, 1000)
  225.         if ret == 0:
  226.             logging.info("get one frame: Width[%d], Height[%d], nFrameNum[%d]" % (stDeviceList.nWidth, stDeviceList.nHeight, stDeviceList.nFrameNum))
  227.  
  228.             nRGBSize = stDeviceList.nWidth * stDeviceList.nHeight * 3
  229.             stConvertParam=MV_SAVE_IMAGE_PARAM_EX()
  230.             stConvertParam.nWidth = stDeviceList.nWidth
  231.             stConvertParam.nHeight = stDeviceList.nHeight
  232.             stConvertParam.pData = data_buf
  233.             stConvertParam.nDataLen = stDeviceList.nFrameLen
  234.             stConvertParam.enPixelType = stDeviceList.enPixelType
  235.             stConvertParam.nImageLen = stConvertParam.nDataLen
  236.             stConvertParam.nJpgQuality = 70
  237.             stConvertParam.enImageType = MV_Image_Jpeg
  238.             stConvertParam.pImageBuffer = (c_ubyte * nRGBSize)()
  239.             stConvertParam.nBufferSize = nRGBSize
  240.             # ret = cam.MV_CC_ConvertPixelType(stConvertParam)
  241.             logging.info("nImageLen: %d" % stConvertParam.nImageLen)
  242.             ret = cam.MV_CC_SaveImageEx2(stConvertParam)
  243.             if ret != 0:
  244.                 logging.error("convert pixel fail ! ret[0x%x]" % ret)
  245.                 del data_buf
  246.                 sys.exit()
  247.             #file_path = "AfterConvert_RGB2.jpg"
  248.             #file_open = open(file_path, 'wb+')
  249.             #file_open = open(file_path.encode('utf8'), 'wb')
  250.             img_buff = (c_ubyte * stConvertParam.nImageLen)()
  251.             cdll.msvcrt.memcpy(byref(img_buff), stConvertParam.pImageBuffer, stConvertParam.nImageLen)
  252.             #file_open.write(img_buff)
  253.             
  254.             # 对返回的图片进行 base64 格式转换
  255.             img_base64 = "data:image/jpg;base64," + str(base64.b64encode(img_buff)).split("'")[1]
  256.             code = 200
  257.             msg = "success"
  258.         logging.info("Save Image succeed!")
  259.  
  260.         # ch:停止取流 | en:Stop grab image
  261.         ret = cam.MV_CC_StopGrabbing()
  262.         if ret != 0:
  263.             logging.error("stop grabbing fail! ret[0x%x]" % ret)
  264.             del data_buf
  265.             sys.exit()
  266.  
  267.         # ch:关闭设备 | Close device
  268.         ret = cam.MV_CC_CloseDevice()
  269.         if ret != 0:
  270.             logging.error("close deivce fail! ret[0x%x]" % ret)
  271.             del data_buf
  272.             sys.exit()
  273.  
  274.         # ch:销毁句柄 | Destroy handle
  275.         ret = cam.MV_CC_DestroyHandle()
  276.         if ret != 0:
  277.             logging.error("destroy handle fail! ret[0x%x]" % ret)
  278.             del data_buf
  279.             sys.exit()
  280.  
  281.         del data_buf
  282.     except Exception as e:
  283.         logging.error("openAndSave error: %s" % str(e))
  284.     # print("openAndSave finished, current_time: " + str(datetime.datetime.now()))  
  285.   
  286.     return JsonResponse(code, msg, img_base64)
  287.  
  288. # 执行web服务, 端口号可自行修订
  289. logging.info("start to run camera app, current_time: " + str(datetime.datetime.now()))
  290. app.run(host='0.0.0.0', port=65432, debug=True, threaded=True)
  1. # -- coding: utf-8 --
  2. import cv2
  3. from flask import Flask, render_template, Response
  4.  
  5. import sys
  6. import msvcrt
  7. import base64
  8. import datetime
  9. import logging
  10.  
  11. sys.path.append("./MvImport")
  12. from MvCameraControl_class import *
  13. from JsonResponse import *
  14. from JsonFlask import *
  15.  
  16. logging.basicConfig(level=logging.DEBUG,#控制台打印的日志级别
  17.                     filename='hikrobot.log',
  18.                     filemode='a',##模式，有w和a，w就是写模式，每次都会重新写日志，覆盖之前的日志
  19.                     #a是追加模式，默认如果不写的话，就是追加模式
  20.                     format=
  21.                     '%(asctime)s - %(pathname)s[line:%(lineno)d] - %(levelname)s: %(message)s'
  22.                     #日志格式
  23.                     )
  24.  
  25. # 这里配置一下 template_folder为当前目录，不然可以找不到 index.html
  26. app = JsonFlask(__name__, template_folder='.')
  27.  
  28. # index
  29. @app.route('/')
  30. def index():
  31.     return render_template('./templates/index.html')
  32.  
  33. # 获取码流
  34. def generate(cap):
  35.     # 捕获异常信息
  36.     try:
  37.         while True:
  38.             # 如果是关闭相机，先退出取视频流的循环
  39.             global open
  40.             if (not open):
  41.                 break;
  42.             retgrab = cap.grab()
  43.             if retgrab == True:
  44.                 logging.debug("Grab true")
  45.             ret1, frame = cap.retrieve()
  46.             # print(type(frame))
  47.             if frame is None:
  48.                 logging.error("frame is None")
  49.                 continue
  50.             ret1, jpeg = cv2.imencode('.jpg', frame)
  51.             jpg_frame = jpeg.tobytes()
  52.             yield (b'--frame\r\n'
  53.                 b'Content-Type: image/jpeg\r\n\r\n' + jpg_frame + b'\r\n')
  54.     except Exception as e:
  55.         logging.error("generate error: %s" % str(e))
  56.  
  57.  
  58. # 开始预览
  59. @app.route('/startPreview')
  60. def startPreview():
  61.     logging.info("================== startPreview start ====================")
  62.     logging.info("start to preview video stream, current_time: " + str(datetime.datetime.now()))
  63.     # 全局变量，用于控制获取视频流的开关状态
  64.     try:
  65.         global open
  66.         open = True
  67.  
  68.         # 全局变量，获取视频连接
  69.         global cap
  70.         cap = cv2.VideoCapture(1)
  71.  
  72.         if False == cap.isOpened():
  73.             logging.error("startPreview -- can't open camera")
  74.             quit()
  75.         else:
  76.             logging.info("startPreview -- start to open camera")
  77.  
  78.         logging.info("startPreview -- open camera ok")
  79.  
  80.         # 分辨率设置 3072*2048（海康机器人工业相机 MV-CU060-10GM）
  81.         cap.set(cv2.CAP_PROP_FRAME_WIDTH, 3072)
  82.         cap.set(cv2.CAP_PROP_FRAME_HEIGHT, 2048)
  83.         # 帧率配置
  84.         cap.set(cv2.CAP_PROP_FPS, 15)   
  85.         response = Response(generate(cap), mimetype='multipart/x-mixed-replace;boundary=frame')
  86.     except Exception as e:
  87.         logging.error("startPreview error: %s" % str(e))
  88.     return response
  89.  
  90. # 停止预览
  91. @app.route('/stopPreview')
  92. def stopPreview():
  93.     logging.info("================== stopPreview start ====================")
  94.     logging.info("stop to preview video stream, current_time: " + str(datetime.datetime.now()))
  95.     logging.info("start to close camera")
  96.  
  97.     # 全局变量，用于停止循环
  98.     global open
  99.     open = False
  100.  
  101.     logging.info("release resources start")
  102.     # 全局变量，用于释放相机资源
  103.     try:
  104.         global cap
  105.         cap.release()
  106.         cv2.destroyAllWindows()
  107.     except Exception as e:
  108.         logging.error("stopPreview error: %s" % str(e))
  109.     logging.info("release resources end")
  110.     logging.info("camera closed successfully, current_time: " + str(datetime.datetime.now()))
  111.     logging.info("=================== stopPreview end ===================")
  112.     return "stop to preview"
  113.  
  114. # 获取base64图片
  115. @app.route('/grabImage')
  116. def grabImage():
  117.     code = 100000
  118.     msg = "连接相机时发生错误"
  119.     # 捕获异常信息
  120.     try:
  121.         print("grabImage -- stopPreview start")
  122.         stopPreview()
  123.         print("grabImage -- stopPreview end")
  124.  
  125.         # 全局变量，获取视频连接
  126.         global cap
  127.         cap = cv2.VideoCapture(1)
  128.  
  129.         if False == cap.isOpened():
  130.             logging.error("can't open camera")
  131.             quit()
  132.         else:
  133.             logging.info("grabImage -- start to open camera")
  134.  
  135.         logging.info("grabImage -- open camera ok")
  136.  
  137.         # 分辨率设置 3072*2048（海康机器人工业相机 MV-CU060-10GM）
  138.         cap.set(cv2.CAP_PROP_FRAME_WIDTH, 3072)
  139.         cap.set(cv2.CAP_PROP_FRAME_HEIGHT, 2048)
  140.         # 帧率配置
  141.         cap.set(cv2.CAP_PROP_FPS, 15)   
  142.         
  143.         retgrab1 = cap.grab()
  144.         if retgrab1 == True:
  145.             logging.debug("grabImage -- Grab true")
  146.         ret1, frame = cap.retrieve()
  147.         ret1, jpeg = cv2.imencode('.jpg', frame)
  148.         img_buff = jpeg.tobytes()
  149.  
  150.         # 对返回的图片进行 base64 格式转换
  151.         img_base64 = "data:image/jpg;base64," + str(base64.b64encode(img_buff)).split("'")[1]
  152.         code = 200
  153.         msg = "success"
  154.  
  155.         stopPreview()
  156.     except Exception as e:
  157.         logging.error("generate error: %s" % str(e))
  158.  
  159.     return JsonResponse(code, msg, img_base64)
  160.  
  161. # 获取base64图片
  162. @app.route('/hik/openAndSave')
  163. def openAndSave():
  164.     code = 100000
  165.     msg = "连接相机时发生错误"
  166.     # 捕获异常信息
  167.     try:
  168.         logging.info("================= openAndSave start =====================")
  169.         # 拍照之前，先停止预览
  170.         stopPreview()
  171.         logging.info("start to grab image, current_time: " + str(datetime.datetime.now()))
  172.  
  173.         # 全局变量，获取视频连接
  174.         global cap
  175.         cap = cv2.VideoCapture(1)
  176.  
  177.         if False == cap.isOpened():
  178.             logging.error("openAndSave -- can't open camera")
  179.             quit()
  180.         else:
  181.             logging.info("openAndSave -- start to open camera")
  182.  
  183.         logging.info("openAndSave -- open camera ok")
  184.  
  185.         # 分辨率设置 3072*2048（海康机器人工业相机 MV-CU060-10GM）
  186.         cap.set(cv2.CAP_PROP_FRAME_WIDTH, 3072)
  187.         cap.set(cv2.CAP_PROP_FRAME_HEIGHT, 2048)
  188.         # 帧率配置
  189.         cap.set(cv2.CAP_PROP_FPS, 15)   
  190.         
  191.         retgrab1 = cap.grab()
  192.         if retgrab1 == True:
  193.             logging.debug("openAndSave -- Grab true")
  194.         ret1, frame = cap.retrieve()
  195.         ret1, jpeg = cv2.imencode('.jpg', frame)
  196.         img_buff = jpeg.tobytes()
  197.  
  198.         # 对返回的图片进行 base64 格式转换
  199.         img_base64 = "data:image/jpg;base64," + str(base64.b64encode(img_buff)).split("'")[1]
  200.         code = 200
  201.         msg = "success"
  202.  
  203.         stopPreview()
  204.         logging.info("================= openAndSave end =====================")
  205.     except Exception as e:
  206.         logging.error("openAndSave error: %s" % str(e))
  207.  
  208.     return JsonResponse(code, msg, img_base64)
  209.  
  210. @app.route('/hik/openAndSave2')
  211. def openAndSave2():
  212.     # 拍照之前，先停止预览
  213.     stopPreview()
  214.     logging.info("======================================")
  215.     logging.info("start to grab image, current_time: " + str(datetime.datetime.now()))
  216.     code = 100000
  217.     msg = "连接相机时发生错误"
  218.     # img_base64 = None
  219.     try:
  220.         deviceList = MV_CC_DEVICE_INFO_LIST()
  221.         tlayerType = MV_GIGE_DEVICE | MV_USB_DEVICE
  222.  
  223.         # ch:枚举设备 | en:Enum device
  224.         ret = MvCamera.MV_CC_EnumDevices(tlayerType, deviceList)
  225.         if ret != 0:
  226.             logging.error("enum devices fail! ret[0x%x]" % ret)
  227.             sys.exit()
  228.  
  229.         if deviceList.nDeviceNum == 0:
  230.             logging.error("find no device!")
  231.             sys.exit()
  232.  
  233.         logging.info("find %d devices!" % deviceList.nDeviceNum)
  234.  
  235.         for i in range(0, deviceList.nDeviceNum):
  236.             mvcc_dev_info = cast(deviceList.pDeviceInfo[i], POINTER(MV_CC_DEVICE_INFO)).contents
  237.             if mvcc_dev_info.nTLayerType == MV_GIGE_DEVICE:
  238.                 logging.info("\ngige device: [%d]" % i)
  239.                 strModeName = ""
  240.                 for per in mvcc_dev_info.SpecialInfo.stGigEInfo.chModelName:
  241.                     strModeName = strModeName + chr(per)
  242.                 logging.info("device model name: %s" % strModeName)
  243.  
  244.                 nip1 = ((mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0xff000000) >> 24)
  245.                 nip2 = ((mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0x00ff0000) >> 16)
  246.                 nip3 = ((mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0x0000ff00) >> 8)
  247.                 nip4 = (mvcc_dev_info.SpecialInfo.stGigEInfo.nCurrentIp & 0x000000ff)
  248.                 logging.info("current ip: %d.%d.%d.%d\n" % (nip1, nip2, nip3, nip4))
  249.             elif mvcc_dev_info.nTLayerType == MV_USB_DEVICE:
  250.                 logging.info("\nu3v device: [%d]" % i)
  251.                 strModeName = ""
  252.                 for per in mvcc_dev_info.SpecialInfo.stUsb3VInfo.chModelName:
  253.                     if per == 0:
  254.                         break
  255.                     strModeName = strModeName + chr(per)
  256.                 logging.info("device model name: %s" % strModeName)
  257.  
  258.                 strSerialNumber = ""
  259.                 for per in mvcc_dev_info.SpecialInfo.stUsb3VInfo.chSerialNumber:
  260.                     if per == 0:
  261.                         break
  262.                     strSerialNumber = strSerialNumber + chr(per)
  263.                 logging.info("user serial number: %s" % strSerialNumber)
  264.  
  265.         nConnectionNum = 0
  266.  
  267.         if int(nConnectionNum) >= deviceList.nDeviceNum:
  268.             logging.error("intput error!")
  269.             sys.exit()
  270.  
  271.         # ch:创建相机实例 | en:Creat Camera Object
  272.         cam = MvCamera()
  273.  
  274.         # ch:选择设备并创建句柄 | en:Select device and create handle
  275.         stDeviceList = cast(deviceList.pDeviceInfo[int(nConnectionNum)], POINTER(MV_CC_DEVICE_INFO)).contents
  276.  
  277.         ret = cam.MV_CC_CreateHandle(stDeviceList)
  278.         if ret != 0:
  279.             logging.error("create handle fail! ret[0x%x]" % ret)
  280.             sys.exit()
  281.  
  282.         # ch:打开设备 | en:Open device
  283.         ret = cam.MV_CC_OpenDevice(MV_ACCESS_Exclusive, 0)
  284.         if ret != 0:
  285.             logging.error("open device fail! ret[0x%x]" % ret)
  286.             sys.exit()
  287.  
  288.         # ch:探测网络最佳包大小(只对GigE相机有效) | en:Detection network optimal package size(It only works for the GigE camera)
  289.         if stDeviceList.nTLayerType == MV_GIGE_DEVICE:
  290.             nPacketSize = cam.MV_CC_GetOptimalPacketSize()
  291.             if int(nPacketSize) > 0:
  292.                 ret = cam.MV_CC_SetIntValue("GevSCPSPacketSize", nPacketSize)
  293.                 if ret != 0:
  294.                     logging.warn("Warning: Set Packet Size fail! ret[0x%x]" % ret)
  295.             else:
  296.                 logging.warn("Warning: Get Packet Size fail! ret[0x%x]" % nPacketSize)
  297.  
  298.         # ch:设置触发模式为off | en:Set trigger mode as off
  299.         ret = cam.MV_CC_SetEnumValue("TriggerMode", MV_TRIGGER_MODE_OFF)
  300.         if ret != 0:
  301.             logging.error("set trigger mode fail! ret[0x%x]" % ret)
  302.             sys.exit()
  303.  
  304.         # ch:获取数据包大小 | en:Get payload size
  305.         stParam = MVCC_INTVALUE()
  306.         memset(byref(stParam), 0, sizeof(MVCC_INTVALUE))
  307.  
  308.         ret = cam.MV_CC_GetIntValue("PayloadSize", stParam)
  309.         if ret != 0:
  310.             logging.error("get payload size fail! ret[0x%x]" % ret)
  311.             sys.exit()
  312.             
  313.         nPayloadSize = stParam.nCurValue
  314.  
  315.         # ch:开始取流 | en:Start grab image
  316.         ret = cam.MV_CC_StartGrabbing()
  317.         if ret != 0:
  318.             logging.error("start grabbing fail! ret[0x%x]" % ret)
  319.             sys.exit()
  320.  
  321.         stDeviceList = MV_FRAME_OUT_INFO_EX()
  322.         memset(byref(stDeviceList), 0, sizeof(stDeviceList))
  323.         data_buf = (c_ubyte * nPayloadSize)()
  324.         
  325.         ret = cam.MV_CC_GetOneFrameTimeout(byref(data_buf), nPayloadSize, stDeviceList, 1000)
  326.         if ret == 0:
  327.             logging.info("get one frame: Width[%d], Height[%d], nFrameNum[%d]" % (stDeviceList.nWidth, stDeviceList.nHeight, stDeviceList.nFrameNum))
  328.  
  329.             nRGBSize = stDeviceList.nWidth * stDeviceList.nHeight * 3
  330.             stConvertParam=MV_SAVE_IMAGE_PARAM_EX()
  331.             stConvertParam.nWidth = stDeviceList.nWidth
  332.             stConvertParam.nHeight = stDeviceList.nHeight
  333.             stConvertParam.pData = data_buf
  334.             stConvertParam.nDataLen = stDeviceList.nFrameLen
  335.             stConvertParam.enPixelType = stDeviceList.enPixelType
  336.             stConvertParam.nImageLen = stConvertParam.nDataLen
  337.             stConvertParam.nJpgQuality = 70
  338.             stConvertParam.enImageType = MV_Image_Jpeg
  339.             stConvertParam.pImageBuffer = (c_ubyte * nRGBSize)()
  340.             stConvertParam.nBufferSize = nRGBSize
  341.             # ret = cam.MV_CC_ConvertPixelType(stConvertParam)
  342.             logging.info("nImageLen: %d" % stConvertParam.nImageLen)
  343.             ret = cam.MV_CC_SaveImageEx2(stConvertParam)
  344.             if ret != 0:
  345.                 logging.error("convert pixel fail ! ret[0x%x]" % ret)
  346.                 del data_buf
  347.                 sys.exit()
  348.             #file_path = "AfterConvert_RGB2.jpg"
  349.             #file_open = open(file_path, 'wb+')
  350.             #file_open = open(file_path.encode('utf8'), 'wb')
  351.             img_buff = (c_ubyte * stConvertParam.nImageLen)()
  352.             cdll.msvcrt.memcpy(byref(img_buff), stConvertParam.pImageBuffer, stConvertParam.nImageLen)
  353.             #file_open.write(img_buff)
  354.             
  355.             # 对返回的图片进行 base64 格式转换
  356.             img_base64 = "data:image/jpg;base64," + str(base64.b64encode(img_buff)).split("'")[1]
  357.             code = 200
  358.             msg = "success"
  359.         logging.info("Save Image succeed!")
  360.  
  361.         # ch:停止取流 | en:Stop grab image
  362.         ret = cam.MV_CC_StopGrabbing()
  363.         if ret != 0:
  364.             logging.error("stop grabbing fail! ret[0x%x]" % ret)
  365.             del data_buf
  366.             sys.exit()
  367.  
  368.         # ch:关闭设备 | Close device
  369.         ret = cam.MV_CC_CloseDevice()
  370.         if ret != 0:
  371.             logging.error("close deivce fail! ret[0x%x]" % ret)
  372.             del data_buf
  373.             sys.exit()
  374.  
  375.         # ch:销毁句柄 | Destroy handle
  376.         ret = cam.MV_CC_DestroyHandle()
  377.         if ret != 0:
  378.             logging.error("destroy handle fail! ret[0x%x]" % ret)
  379.             del data_buf
  380.             sys.exit()
  381.  
  382.         del data_buf
  383.     except Exception as e:
  384.         logging.error("openAndSave error: %s" % str(e))
  385.     # print("openAndSave finished, current_time: " + str(datetime.datetime.now()))  
  386.   
  387.     return JsonResponse(code, msg, img_base64)
  388.  
  389. # 执行web服务, 端口号可自行修订
  390. logging.info("start to run camera app, current_time: " + str(datetime.datetime.now()))
  391. if __name__ == '__main__':
  392.     try:
  393.         app.run(host='0.0.0.0', port=65432, debug=True, threaded=True)
  394.     except Exception as e:
  395.         logging.error("app error: %s" % str(e))

6、功能验证
1）开始预览
可以将 http://127.0.0.1:65432/startPreview 在前端用 img 标签 显示视频的实时预览效果。

http://127.0.0.1:65432/startPreview


2）停止预览
由于使用的这款海康机器人工业相机（MV-CU060-10GM）只能创建一个连接，所以，当预览完实时视频，需要调用该接口释放相机资源，避免资源被长期占用。

http://127.0.0.1:65432/stopPreview


3）获取图片
返回 base64 格式 的图片，前端可以直接接收显示，调用上传接口保存。

http://127.0.0.1:65432/openAndSave


版权声明：本文为CSDN博主「龙凌云」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/aikudexiaohai/article/details/130078959

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/羊村懒王/article/detail/357878
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号