使用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 发布 
 


		  	

    
    




    
    
    


推荐阅读

           
                  
              
                  银耳煮不烂是什么原因 银耳怎么煮容易烂 
                
                   
                
              
            

                  
              
                  萝卜羊肉馅水饺怎么做 羊肉萝卜馅饺子怎样做 
                
                   
                
              
            

                  
              
                  计算机进银行后悔死了 银行考试都考什么 
                
                   
                
              
            

                  
              
                  佳能5dmark3新手入门图解 佳能5dmark3评测 
                
                   
                
              
            

                  
              
                  空洞骑士梦之门怎么用 
                
                   
                
              
            

                  
              
                  手机淘宝删除的订单还能找到吗 
                
                   
                
              
            

                  
              
                  腰围80厘米是几尺几呀 
                
                   
                
              
            

                  
              
                  安卓模拟器 手机型号,安卓模拟器怎么用? 
                
                   
                
              
            

                  
              
                  眼皮抽脂几天能碰水 
                
                   
                
              
            

                  
              
                  英冠联赛积分榜比分_英冠联赛积分榜比分表最新 
                
                   
                
              
            

                  
              
                  微信朋友圈跟qq空间同步设置 
                
                   
                
              
            

                  
              
                  兔子养在外面会冻死吗 
                
                   
                
              
            

                  
              
                  想做一个农家乐有什么建议？做垂钓怎么样？ 
                
                   
                
              
            

                  
              
                  如何购买钻石呢 
                
                   
                
              
            

                  
              
                  spring|spring security 之自定义表单登录源码跟踪 
                
                   
                
              
            

                  
              
                  如何为战术战队设置服务器？ 战术战队怎么设置服务器 
                
                   
                
              
            

                  
              
                  奥克斯空调显示e5是什么意思 
                
                   
                
              
            

                  
              
                  “人生最大的幸福,是发现自己爱的人正好也爱着自己”,你怎么看？ 
                
                   
                
              
            

                  
              
                  光谱图像分析,多光谱图像融合 
                
                   
                
              
            

                  
              
                  c高级编程第11版，unix环境高级编程程序清单117简化加解锁的问题 有个问题APUE 
                
                   
                
              
            

          

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