DeepStream系列之kafka IoT功能实现

点击查看系列文章目录

0 背景

从 deepstream3.0 开始，提供了 nvmsgconv 与 nvmsgbroker 两个插件，可以实现将检测结果通过多种协议，如 kafka、amqp、azure 等发送到服务端，实现一个物联网功能。本文以 deepstream-test4，介绍该功能的具体实现方法。

测试环境：x86 GPU T4, docker deepstream-6.1

1 插件介绍

首先，deepstream-test4 实现的 pipeline 如下所示（点击可放大）

可以看到，在输出部分有两个分支，一个分支是在屏幕进行显示，另一个分支通过 msgconv 和 msgbroker 两个插件进行数据上报。首先对这两个插件的功能进行一个简单的介绍。

1.1 nvmsgconv

插件地址：Gst-nvmsgconv — DeepStream 6.1.1 Release documentation

该插件的功能就是将前