NVIDIA 文档中心 NVIDIA Morpheus NVIDIA Morpheus (24.10.01) 批量数据负载模块

批量数据负载模块

此模块根据指定的配置将传入的控制消息数据负载分批成更小的批次。

可配置参数

参数	类型	描述	示例值	默认值
`max_batch_size`	整数	每个批次的最大大小	256	`256`
`raise_on_failure`	布尔值	如果在处理过程中发生故障，是否引发异常	false	`false`
`group_by_columns`	列表	分批时要分组的列名	`["col1", "col2"]`	`[]`
`disable_max_batch_size`	布尔值	是否禁用 `max_batch_size` 并仅按组分批	false	`false`
`timestamp_column_name`	字符串	时间戳列的名称	None	`None`
`timestamp_pattern`	字符串	解析时间戳列的模式	None	`None`
`period`	字符串	按时间戳分组的周期	H	`D`

JSON 配置示例

复制
已复制!

            
            {
  "max_batch_size": 256,
  "raise_on_failure": false,
  "group_by_columns": [],
  "disable_max_batch_size": false,
  "timestamp_column_name": null,
  "timestamp_pattern": null,
  "period": "D"
}

上一个 MLflow 模型写入模块

下一个序列化模块