set_attr

函数功能

设置FlowNode的属性。

函数原型

set_attr(attr_name, attr_value)

参数说明

参数名称	数据类型	取值说明
attr_name	str	属性名称当前支持如下三种： _flow_attr: BOOL类型属性，可以配置为true或false，true表示存在flow属性，false表示不存在flow属性。 _flow_attr_depth: INT类型属性，指定了队列的深度，范围: 大于等于2，若不配置，默认深度为128。 _flow_attr_enqueue_policy: STRING类型属性，指定的入队的策略，仅支持"FIFO"和"OVERWRITE"，"FIFO"表示队列数据顺序入队，队列满的时候会等待dequeue，"OVERWRITE"表示入队不会等待，数据会循环覆盖，若不配置，默认策略为FIFO。
attr_value	Union[bool, str, int]	属性值。

参数名称

数据类型

取值说明

attr_name

str

属性名称

当前支持如下三种：

_flow_attr: BOOL类型属性，可以配置为true或false，true表示存在flow属性，false表示不存在flow属性。
_flow_attr_depth: INT类型属性，指定了队列的深度，范围: 大于等于2，若不配置，默认深度为128。
_flow_attr_enqueue_policy: STRING类型属性，指定的入队的策略，仅支持"FIFO"和"OVERWRITE"，"FIFO"表示队列数据顺序入队，队列满的时候会等待dequeue，"OVERWRITE"表示入队不会等待，数据会循环覆盖，若不配置，默认策略为FIFO。

attr_value

Union[bool, str, int]

属性值。

返回值

正常场景下返回None。

返回“TypeError”表示参数类型不正确。

调用示例

import dataflow as df
pp = df.FuncProcessPoint(...)
flow_node = df.FlowNode(...)
flow_node.set_attr("_flow_attr",True)
flow_node.set_attr("_flow_attr_depth",5)
flow_node.set_attr("_flow_attr_enqueue_policy","FIFO")

约束说明

通过_flow_attr_depth和_flow_attr_enqueue_policy设置depth和policy需要先使能_flow_attr，否则不会生效。

父主题： dataflow.FlowNode