environment: docker container with samples rev for deepstream5.1
I want to run the deepstream under python code to send my own kafka message with my own model. I have successfully sending the kafka message with my own model but I don’t know how to revise the message format by myself. Hope somebody help to show me the detail, thanks in advance!
Your topic was posted in the wrong category. I am moving this to the DeepStream SDK category for visibility.
What format do you want to revise? Could you refer our demo code below?
https://github.com/NVIDIA-AI-IOT/deepstream_python_apps/tree/master/apps/deepstream-test4
Thanks！
Yes, I had checked this code, it seems the message have already defined in the c code? I want to define the message by my own model with my class_names.
You can refer the user guide and the demo code below to learn how to use our msgconv plugin.
https://docs.nvidia.com/metropolis/deepstream/dev-guide/text/DS_plugin_gst-nvmsgbroker.html#nvds-kafka-proto-kafka-protocol-adapter
Thanks, I will check it.
Or, is it possible to replace the block of msg-converter and broker by pykafka?
I had tried to comment out the queue for msgconv and add the pykafka code in tiler_src_pad_buffer_probe function, and I find it works. But I’m not clear whether it may affect the program process?
We didn’t suggest you replace it. The two plugins are at the C layer actually. The framework will use the C plugins by default. If you want to replace it, you may need to change lots of codes.
I had replace the code, and found the message can be sent successfully.
As your suggestion, I want to redefine the message, but I’m not clear how to define the message in C layer… for the original is only suitable for the classes of CAR, PERSON and so on. But I want to change it to my own class names.
You don’g have to define your message in the code, just in the config file.You can refer the link below:
https://docs.nvidia.com/metropolis/deepstream/dev-guide/text/DS_plugin_gst-nvmsgconv.html
You can also refer our demo code below:
https://github.com/NVIDIA-AI-IOT/deepstream_python_apps/tree/master/apps/deepstream-test4
Many thanks for your kind help, I will check the detail.
Do you still need support for this topic? Or should we close it? Thanks.