本文主要是介绍deepstream_python_apps_test4之README，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
环境需求
- DeepStreamSDK 5.1
- Python 3.6
- Gst-python
- Deepstream msgbroker支持发送信息到Azure(mqtt) IOThub, kafka 和 AMQP(rabbitmq)
依赖
$ sudo apt-get update
Azure Iot
$ sudo apt-get install -y libcurl4-openssl-dev libssl-dev uuid-dev libglib2.0 libglib2.0-dev
如果是ubuntu1804的系统且是x86的，需要下面的额外安装包
$ sudo apt-get install -y libcurl3
Kafka
$ sudo apt-get install libglib2.0 libglib2.0-dev$ sudo apt-get install libjansson4 libjansson-dev$ sudo apt-get install librdkafka1=0.11.3-1build1
AMQP (rabbitmq)
安装rabbitmq-c库
$ git clone -b v0.8.0 --recursive https://github.com/alanxz/rabbitmq-c.git$ cd rabbitmq-c$ mkdir build && cd build$ cmake ..$ cmake --build .$ sudo cp librabbitmq/librabbitmq.so.4 /opt/nvidia/deepstream/deepstream-<version>/lib/$ sudo ldconfig
步骤
1.使用–proto-lib 或者 -p 给出adaptor共享库的路径
在/opt/nvidia/deepstream/deepstream-/lib中。
- kafka lib - libnvds_kafka_proto.so
- azure device client - libnvds_azure_proto.so
- AMQP lib - libnvds_amqp_proto.so
2.使用–conn-str 给出连接服务器的参数。
- Azure - 完成Azure连接字符串
- Kafka - 格式 host;port;topic
- Amqp - 格式 host;port;username 密码在cfg_amqp.txt示例： --conn-str="host;port;topic"
3.使用 --topic 或者 -t 给出topic名称(可选参数)。
kafka的topic已经给在连接参数中，此时的topic要与连接参数中的一致。
4.使用 --schema 或者 -s 来配置消息策略(可选参数).
- schema = 0; Full 消息策略，每个对象是个单独的有效载荷 (默认)
- schema = 1; Minimal 消息策略，多个对象在同一个有效载荷
关于消息策略，可在用户手册查看详细信息
5.使用–no-display 来禁用显示
6.使用 --cfg-file 或者 -c 给出adaptor的配置文件.
如果连接参数中有所有相关信息，这个参数可以不用给出。
-
kafka: 参考 cfg_kafka.txt.
定义发送消息给kafka时的部分关键字段。
其他的配置参数详见DeepStream 4.0 Plugin Manual中Kafka Protocol Adaptor部分。
cfg_kafka.txt文件中的partition-key配置应该基于–schema指定的消息策略类型
“sensor.id”： Full 消息策略；
“sensorId”： Minimal消息策略。 -
Azure：参考 cfg_azure.txt. 有如下部分：
[message-broker]
#connection_str = HostName=<my-hub>.azure-devices.net;DeviceId=<device_id>;SharedAccessKey=<my-policy-key>
#shared_access_key = <my-policy-key>
Azure 设备连接字符串:
可在cfg_azure.txt中按如下格式给出连接参数：
connection_str = HostName=<my-hub>.azure-devices.net;DeviceId=<device_id>;SharedAccessKey=<my-policy-key>
或者
可用–conn-str 按格式: “url;port;device-id” 给出连接参数。
然后在cfg_azure.txt中按以下格式给出shared_access_key
shared_access_key = <my-policy-key>
- AMQP, 参考 cfg_amqp.txt. 有如下默认的参数:
[message-broker]password = guest#optionalhostname = localhostusername = guestport = 5672exchange = amq.topictopic = topicname
AMQP 连接字符串:
在cfg_amqp.txt文件中给出hostname, username, password
或者
可用–conn-str按如下格式给出连接字符串: “hostname;port;username”
然后在cfg_amqp.txt中按如下格式给出password
password = <your_amqp_broker_password>
NOTE
- 不要删除cfg文件中的[message-broker]行，是解析用的section id。
- Azure & AMQP:
如果使用第2步中的–conn-str命令行参数，确保在cfg文件中给出password
或者命令行不给–conn-str，直接在cfg文件中给出所有连接参数。
7.使用logging
通过下面命令查看README文件内容来配置和使用为消息库(kafka, azure, amqp)准备的logging
$ cat ../../../tools/nvds_logger/README
运行
$ python3 deepstream_test_4.py -i <H264 filename> -p <Proto adaptor library> --conn-str=<Connection string> -s <0/1>示例：python3 deepstream_test_4.py -i /opt/nvidia/deepstream/deepstream/samples/streams/sample_720p.h264 -p /opt/nvidia/deepstream/deepstream-5.1/lib/libnvds_kafka_proto.so --conn-str="192.168.8.116;9092;test" -c cfg_kafka.txt -s 0 --no-display
NOTE
其他关于消息adapters的信息，可在下面路径中相应的README里查看
本文档时关于deepstream-test4的应用.
本示例在deepstream-test1基础上构建，新增的内容包含:
- 在pipeline中使用 “nvmsgconv” 和 “nvmsgbroker”
- 新建元数据的NVDS_META_EVENT_MSG类型并关联到buffer
- 使用NVDS_META_EVENT_MSG来发送对象的不同类型消息，比如：车，人等
- 如果元数据从"extMsg"拓展，那会有 copy 和 free 函数。
"nvmsgconv"插件使用buffer中NVDS_META_EVENT_MSG类型的元数据，
生成"DeepStream Schema"中定义样式的json串。
消息策略的静态属性是配置文件中的 key-value 对，参考dstest4_msgconv_config.txt文件。
生成的有效载荷关联buffer中NVDS_META_PAYLOAD类型的元数据。
"nvmsgbroker"插件从buffer中提炼NVDS_META_PAYLOAD类型的元数据，
然后通过protocol adaptor API把有效载荷发送到服务端。
对不同类型的对象生成一般的元数据：
除了NvDsEventMsgMeta结构中给出的普通字段，
用户可以新建普通对象后关联NVDS_META_EVENT_MSG元数据到buffer。
NvDsEventMsgMeta提供了 “extMsg” 和 “extMsgSize” 字段供上述功能实现。
用户可创建一般结构体，赋值，然后将其指针分配为 “extMsg” 并相应配置 “extMsgSize” 大小。
如一般结构中有复杂结构体，不能简单复制的，用户需提供对象的复制和释放函数。
参考generate_event_msg_meta()，给出了 “extMsg” 和 "extMsgSize"在普通对象上的使用，
同时怎么写 copy/free 函数并关联到元数据相应的buffer。
NOTE
本应用默认第一个对象每30帧发送一次消息，若要改变频率，在源码中修改如下片段：
if(is_first_object and not (frame_number%30)) 修改成:
if (not (frame_number % 30)) #获取一帧的所有对象
这篇关于deepstream_python_apps_test4之README的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
