使用Shifu在OpenYurt集群中接入RTSP协议摄像头 go

OpenYurt是一个云边计端算平台，借助OpenYurt的能力，可以将现有的Kubernetes集群转换成OpenYurt集群，并将Kubernetes的能力延伸到边缘侧。OpenYurt为云边端协同开发提供了多样化的功能，如打通云边通信的YurtTunnel，为了方便管理节点单元应用部署/运维的Yurt-App-Manager以及提供了边缘自治的YurtHub。
开发者可以专注于云边端产品上的应用开发而不用担心底层架构的运维。Shifu作为Kubernetes原生的开源物联网开发架构，可以兼容各种物联网设备的协议并将其抽象成一个为微服务软件对象。二者的能力有非常好的互补性。尤其是在OpenYurt中加入了YurtDeviceController以后，Shifu可以用OpenYurt原生的方式来将设备进行抽象，大大提高物联网开发者的开发效率。
使用OpenYurt和Shifu以后，我们可以将原本复杂的IoT，云边协同开发转化为简单的web式开发。
简介
本文是一个在OpenYurt集群中使用Shifu接入RTSP协议摄像头的指南，其中包含Shifu Framework, Docker, Linux, Kubernetes, OpenYurt的基本操作，任何开发者都可以阅读本文来学习Shifu Framework的开发方法。
本文中的Shifu Framework架构如下：
文章图片

北向通过“deviceshifu-http-http”向上开放HTTP API接口，南向通过“rtsp-driver”来和实际设备交互
目标

在server和edge端通过 yurtctl 部署OpenYurt, 并将edge端加入server端的集群
在 edge 端部署网络摄像头的数字孪生
实现通过HTTP对网络摄像头的远程自动化管控

需要的设备

两台运行 Linux的虚拟机，server和edge的配置分别为 4核16G内存和2核8G内存
一个RTSP协议的网络摄像头，本文中用到的摄像头型号为海康威视的 “DS-2DE3Q140CN-W”

软件环境
-CentOS 7.9.2009
-Go v1.17.1
-yurtctl v0.6.1
-kubectl: v1.19.8

(installed by yurtctl)

步骤
第一步：安装并部署OpenYurt集群本文参考了OpenYurt的官方教程，地址为：
https://openyurt.io/docs/v0.6...
首先让我们来下载OpenYurt，从官方的GitHub直接克隆项目：

git clone https://github.com/openyurtio/openyurt.git

接着让我们下载v0.6.1版本的yurtctl

curl -LO https://github.com/openyurtio/openyurt/releases/download/v0.6.1/yurtctl chmod +x yurtctl

server端的部署：在server端创建OpenYurt集群

./yurtctl init --apiserver-advertise-address--openyurt-version latest --passwd 123

看见如下信息即表示集群创建完成，这里的“--token”要记录一下用来将edge节点加入到集群中

文章图片

接下来看一下各个Pod的运行状况，通过“kubectl get pods -A”:

文章图片

遇到的几个问题如果在“ kubectl logs yurt-hub-server -n kube-system”里遇到

文章图片

请尝试“kubectl apply -f config/setup/yurt-controller-manager.yaml”
方法来自: https://github.com/openyurtio...
除此之外，还有几个问题，如在“kubectl logs yurt-hub-server -n kube-system”里遇到如下输出：

文章图片

请尝试“kubectl apply -f config/setup/ yurthub-cfg.yaml”

文章图片

如果在yurt-tunnel-server和yurt-tunnel-agent也遇到了类似的log，通过以下命令来修复yurt-tunnel的RBAC问题：

kubectl apply -f config/setup/yurt-tunnel-agent.yaml kubectl apply -f config/setup/yurt-tunnel-server.yaml

Untaint master节点来运行Shifu的controller：

kubectl taint nodes server node-role.kubernetes.io/master-

文章图片

至此，Server端部署完毕。
Edge 端的部署首先利用刚才server端init以后的token，执行：

./yurtctl join :6443 --token --node-type=edge --discovery-token-unsafe-skip-ca-verification --v=5

文章图片

确认Node状态，通过"kubectl get nodes”：

文章图片

至此，一个server端+一个edge端的集群建立完毕。
第二步：在集群中部署Shifu 接下来让我们把Shifu部署到OpenYurt集群中
在server端，克隆Shifu项目到本地：

git clone https://github.com/Edgenesis/shifu.git cd shifu/

接下来，安装Shifu：

kubectl apply -f k8s/crd/install/shifu_install.yml

文章图片

通过"kubectl get pods -A”检查Pod状态：

文章图片

看到"shifu-crd-system” namespace中的Pod运行即可
至此，Shifu安装完毕。
第三步：部署虚拟摄像头 (camera deviceShifu) OpenYurt提供了非常方便的节点池(NodePool)功能，可以让我们管理节点集群，对集群进行部署。
创建”beijing”节点池：

export WORKER_NODEPOOL="beijing" export EDGE_NODE="edge" cat <



 
 输出如下： 

文章图片 



 
 接着将edge服务器label到”beijing”的NodePool：

 
 kubectl label node $EDGE_NODE apps.openyurt.io/desired-nodepool=beijing


 
  

文章图片 



 
 查看一下NodePool的状况，应该有一个READYNODES：

 
 kubectl get nodepool


 
  

文章图片 



 
 因为物联网的边缘节点通常是分布式在同一场景内的，这里可以使用OpenYurt的UnitedDeployment功能根据NodePool来自动部署 。

 
 安装 Yurt-app-manager

 
 git clone https://github.com/openyurtio/yurt-app-manager.git
cd yurt-app-manager
kubectl apply -f config/setup/all_in_one.yaml


 
  

文章图片 



 
 使用用UnitedDeployment来部署虚拟的海康摄像头，YAML文件如下：

 
 apiVersion: apps.openyurt.io/v1alpha1kind: UnitedDeploymentmetadata:labels:controller-tools.k8s.io: "1.0"name: deviceshifu-hikvision-camera-deploymentspec:selector:matchLabels:app: deviceshifu-hikvision-camera-deploymentworkloadTemplate:deploymentTemplate:metadata:labels:app: deviceshifu-hikvision-camera-deploymentname: deviceshifu-hikvision-camera-deploymentnamespace: defaultspec:selector:matchLabels:app: deviceshifu-hikvision-camera-deploymenttemplate:metadata:labels:app: deviceshifu-hikvision-camera-deploymentspec:containers:- image: edgehub/deviceshifu-http-http:v0.0.1name: deviceshifu-httpports:- containerPort: 8080volumeMounts:- name: deviceshifu-configmountPath: "/etc/edgedevice/config"readOnly: trueenv:- name: EDGEDEVICE_NAMEvalue: "deviceshifu-hikvision-camera"- name: EDGEDEVICE_NAMESPACEvalue: "devices"- image: edgenesis/camera-python:v0.0.1name: camera-pythonports:- containerPort: 11112volumeMounts:- name: deviceshifu-configmountPath: "/etc/edgedevice/config"readOnly: trueenv:- name: EDGEDEVICE_NAMEvalue: "deviceshifu-hikvision-camera"- name: EDGEDEVICE_NAMESPACEvalue: "devices"- name: IP_CAMERA_ADDRESSvalue: ""- name: IP_CAMERA_USERNAMEvalue: ""- name: IP_CAMERA_PASSWORDvalue: ""- name: IP_CAMERA_CONTAINER_PORTvalue: "11112"- name: PYTHONUNBUFFEREDvalue: "1"volumes:- name: deviceshifu-configconfigMap:name: deviceshifu-hikvision-camera-configmap-0.0.1serviceAccountName: edgedevice-satopology:pools:- name: beijingnodeSelectorTerm:matchExpressions:- key: apps.openyurt.io/nodepooloperator: Invalues:- beijingreplicas: 1revisionHistoryLimit: 5


 
 Service文件：

 
 apiVersion: v1kind: Servicemetadata:labels:app: deviceshifu-hikvision-camera-deploymentname: deviceshifu-hikvision-cameranamespace: defaultspec:ports:- port: 80protocol: TCPtargetPort: 8080selector:app: deviceshifu-hikvision-camera-deploymenttype: LoadBalancer


 
 edgeDevice文件：

 
 apiVersion: shifu.edgenesis.io/v1alpha1kind: EdgeDevicemetadata:name: deviceshifu-hikvision-cameranamespace: devicesspec:sku: "HikVision Camera"connection: Ethernetaddress: 0.0.0.0:11112protocol: HTTP


 
 ConfigMap文件：

 
 apiVersion: v1kind: ConfigMapmetadata:name: deviceshifu-hikvision-camera-configmap-0.0.1namespace: defaultdata:driverProperties: |driverSku: HikVisiondriverImage: edgenesis/camera-python:v0.0.1instructions: |capture:info:stream:move/up:move/down:move/left:move/right:telemetries: |device_health:properties:instruction: infoinitialDelayMs: 1000intervalMs: 1000


 
 将这四个文件放到一个目录，如下：

 
 camera-unitedDeployment/ 
├── camera-edgedevice.yaml 
├── deviceshifu-camera-configmap.yaml 
├── deviceshifu-camera-service.yaml 
└── deviceshifu-camera-unitedDeployment.yaml


 
 接下来部署

 
 kubectl apply -f camera-unitedDeployment/


 
  

文章图片 



 
 通过“kubectl get ud”查看UnitedDeployment状态：
 

文章图片 



 
 通过“kubectl get pods -owide”来确认Pod部署在了“beijing” NodePool里的edge服务器中：
 

文章图片 



 
 我们可以在集群中通过“kubectl get edgedevices -n devices”查看Shifu的虚拟设备：
 

文章图片 



 
 再通过“kubectl describe edgedevices -n devices” 查看设备的详细信息如配置，状态等：
 

文章图片 



 
 至此，摄像头孪生部署完毕。

 
 最后一步：运行效果 
 接下来我们来控制摄像头，这里使用一个nginx的pod来代表应用：

 
 kubectl run nginx --image=nginx


 
 待nginx开始运行时，通过“kubectl exec -it nginx -- bash”来进入nginx的命令行：
 

文章图片 



 
 通过以下命令可以直接控制摄像头：

 
 curl deviceshifu-hikvision-camera/move/{up/down/left/right}


 
  

文章图片 



 
 如果我们想查看摄像头当前拍摄以及当前视频流，需要将摄像头的service通过“kubectl port-forward service/deviceshifu-hikvision-camera 30080:80 --address='0.0.0.0'” 代理到本地。

 
 在浏览器中输入服务器的IP加端口号，可以直接查看图像/视频流：

 
 :30080/capture
:30080/stream


 
  

文章图片 



 
 总结

 
 在此篇文章中，我们讲述了如何将Shifu部署在OpenYurt集群中来增加RTSP摄像头的支持。

 
 在将来的文章中，我们也会尝试将Shifu与OpenYurt的yurt device controller进行整合，通过OpenYurt原生的方式延申OpenYurt的能力到更多物联网设备的管理中。

 
 https://openyurt.io/zh/docs/c...

 
 【使用Shifu在OpenYurt集群中接入RTSP协议摄像头】非常感谢您看到了这里，我们期待您的反馈，如果觉得文章写得不错或者有任何建议请毫不犹豫地留言。

 
 
本文由博客群发一文多发等运营工具平台 OpenWrite 发布 
 


		  	

    
    




    
    
    


推荐阅读

           
                  
              
                  榴莲减肥能吃吗 
                
                   
                
              
            

                  
              
                  小组件|Android 也能用 iOS 小组件？超强桌面美化工具，让你每天像换新手机 
                
                   
                
              
            

                  
              
                  香椿可以和菜花一起吃吗？ 
                
                   
                
              
            

                  
              
                  6.13|6.13 准备不充分会心虚 
                
                   
                
              
            

                  
              
                  宁波免费景点有哪些 宁波哪里好玩的景点 
                
                   
                
              
            

                  
              
                  开发app用什么语言最好用知乎，开发聊天软件用什么语言开发好 
                
                   
                
              
            

                  
              
                  空调制热一直开着会坏吗 空调制热开始时不动的原因 
                
                   
                
              
            

                  
              
                  羊肉和秋葵可以一起吃吗 
                
                   
                
              
            

                  
              
                  肉丝翘臀，娱乐圈八大美臀皇后是谁 
                
                   
                
              
            

                  
              
                  狐臭有哪些症状表现 狐臭会传染吗 
                
                   
                
              
            

                  
              
                  无骨的鸡腿肉怎么做的 无骨的鸡腿肉怎么做 
                
                   
                
              
            

                  
              
                  新手适合养什么鱼 新手适合养什么鱼更容易活 
                
                   
                
              
            

                  
              
                  大金变频空调不制热解说解决方法？大金空调不制热是什么原因 
                
                   
                
              
            

                  
              
                  如何在黏土云服务器上组建团队？ 黏土云服务器怎么组队 
                
                   
                
              
            

                  
              
                  花生褐斑病的危害症状 花生褐斑病的防治方法 
                
                   
                
              
            

                  
              
                  云顶之弈10.24神盾射手怎么玩 云顶之弈手游神盾射手站位出装搭配 
                
                   
                
              
            

                  
              
                  10月成长复盘（千里之行，始于足下！万里长征第一步！） 
                
                   
                
              
            

                  
              
                  新车满2年忘了年审 汽车年审多久一次 
                
                   
                
              
            

                  
              
                  抽真空熟牛肉能冷冻吗 抽真空熟牛肉可以冷冻吗 
                
                   
                
              
            

                  
              
                  榨汁机和破壁机的区别 榨汁机和豆浆机和破壁机的区别 
                
                   
                
              
            

          

golang metrics各个指标含义 
 如何用Shifu来接入一个私有驱动的物联网设备 
 在Golang中连接两个字符串的不同方法 
 在Golang中比较字符串的不同方法 
 Golang中var关键字和短声明运算符之间的区别 
 Go和Python编程语言之间有什么区别（） 
 如何在Golang中修剪字节切片（） 
 如何在Golang中分割字符串（） 
 如何在Golang中分割字节切片（）