MessageDemux

View as Markdown

1pipeline = dai.Pipeline()
2demux = pipeline.create(dai.node.MessageDemux)

1dai::Pipeline pipeline;
2auto demux = pipeline.create<dai::node::MessageDemux>();

1# 创建 sync 节点并设置同步阈值
2sync = pipeline.create(dai.node.Sync)
3sync.setSyncThresholdMs(timedelta(milliseconds=100))
4
5# 创建 demux 节点
6demux = pipeline.create(dai.node.MessageDemux)
7
8# 同步多个节点的输出
9rgb.preview.link(sync.inputs["rgb"])
10stereo.depth.link(sync.inputs["depth"])
11script.outputs["out"].link(sync.inputs["script"])
12
13sync.out.link(demux.input) # Sync 输出是一个 MessageGroup，包含来自同步节点的全部消息
14
15# 将 MessageGroup 分解为单独的消息
16demux.outputs["rgb"].link(xout1.input)
17demux.outputs["depth"].link(xout2.input)
18demux.outputs["script"].link(xout3.input)

1// 创建 sync 节点并设置同步阈值
2auto sync = pipeline.create<dai::node::Sync>();
3sync->setSyncThreshold(std::chrono::milliseconds(100));
4
5// 创建 demux 节点
6auto demux = pipeline.create<dai::node::MessageDemux>();
7
8// 同步多个节点的输出
9rgb.preview.link(sync->input["rgb"]);
10stereo.depth.link(sync->input["depth"]);
11script.outputs["out"].link(sync->input["script"]);
12
13sync->out.link(demux->input); // Sync 输出是一个 MessageGroup，包含来自同步节点的全部消息
14
15// 将 MessageGroup 分解为单独的消息
16demux->outputs["rgb"].link(xout1.input);
17demux->outputs["depth"].link(xout2.input);
18demux->outputs["script"].link(xout3.input);