sophgo / sophon-stream

Other
68 stars 10 forks source link

处理完成后,根据推理结果的数据想要发送kafka消息,这个怎么实现 #22

Closed yefeilang closed 4 months ago

yefeilang commented 4 months ago

处理完成后,根据推理结果的数据想要发送kafka消息,这个怎么实现

yefeilang commented 4 months ago

1.是在哪个位置实现,后处理吗 2.怎么获取推理的结果数据

Yi-sir commented 4 months ago
  1. 可以新增一个element,专门做消息队列。这样好处是逻辑基本解耦,而且是异步运行。
  2. 所有数据都保存在ObjectMetadata,可以阅读后处理代码了解相关结果存放在哪个结构体里。
  3. 此功能可以参考tools/http_push element,这个插件是将ObjectMetadata序列化为json后,通过http协议发送。