FlowMsgQueue构造函数

产品	是否支持
Atlas A3 训练系列产品/Atlas A3 推理系列产品	x
Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件	√
Atlas 200I/500 A2 推理产品	x
Atlas 推理系列产品	x
Atlas 训练系列产品	x

FlowMsgQueue构造函数和析构函数。

__init__(self, flow_msg_queue: flowfunc_wrapper.FlowMsgQueue) -> None

参数名	输入/输出	描述
flowfunc_wrapper.FlowMsgQueue	输入	flowfunc_wrapper模块中定义的FlowMsgQueue。实际执行时由C++代码传入，通过pybind11的绑定关系映射成flowfunc_wrapper的FlowMsgQueue对象。

返回FlowMsgQueue类型的对象。

无

继承Python的queue.Queue类型，但只支持get、get_nowait、full、empty、qsize 5种接口。

流式输入（即flow func函数入参为队列）场景下，DataFlow不支持数据对齐和UDF主动上报异常。

父主题： FlowMsgQueue类