6月22日，上海·源创会，云技术专场火热报名中

forked from iresty / Apache APISIX

加入 Gitee

与超过 1200万开发者一起发现、参与优秀开源项目，私有仓库也完全免费：）

克隆/下载

batch-processor.md 2.83 KB

[English](../batch-processor.md)

# 批处理机

批处理处理器可用于聚合条目（日志/任何数据）并进行批处理。
当batch_max_size设置为零时，处理器将立即执行每个条目。将批处理的最大大小设置为大于1将开始聚合条目，直到达到最大大小或超时到期为止

## 构型

创建批处理程序的唯一必需参数是函数。当批处理达到最大大小或缓冲区持续时间超过时，将执行该功能。

|名称           |需求    |描述|
|-------        |-----          |------|
|id             |可选的       |标识批处理者的唯一标识符|
|batch_max_size |可选的       |每批的最大大小，默认为1000|
|inactive_timeout|可选的      |如果不活动，将刷新缓冲区的最大时间（以秒为单位），默认值为5s|
|buffer_duration|可选的       |必须先处理批次中最旧条目的最大期限（以秒为单位），默认是5|
|max_retry_count|可选的       |从处理管道中移除之前的最大重试次数；默认为零|
|retry_delay    |可选的       |如果执行失败，应该延迟进程执行的秒数；默认为1|

以下代码显示了如何使用批处理程序的示例。批处理处理器将要执行的功能作为第一个参数，将批处理配置作为第二个参数。

```lua
local bp = require("apisix.plugins.batch-processor")
local func_to_execute = function(entries)
            -- serialize to json array core.json.encode(entries)
            -- process/send data
            return true
       end

local config = {
    max_retry_count  = 2,
    buffer_duration  = 60,
    inactive_timeout  = 5,
    batch_max_size = 1,
    retry_delay  = 0
}

local batch_processor, err = bp:new(func_to_execute, config)

if batch_processor then
    batch_processor:push({hello='world'})
end
```

注意：请确保批处理的最大大小（条目数）在函数执行的范围内。
刷新批处理的计时器基于“ inactive_timeout”配置运行。因此，为了获得最佳使用效果，
保持“ inactive_timeout”小于“ buffer_duration”。

一键复制编辑原始数据按行查看历史

提交于 2020-06-19 06:03 . doc: Refactoring docs to support docsify (#1724)

批处理机

批处理处理器可用于聚合条目（日志/任何数据）并进行批处理。当batch_max_size设置为零时，处理器将立即执行每个条目。将批处理的最大大小设置为大于1将开始聚合条目，直到达到最大大小或超时到期为止

构型

创建批处理程序的唯一必需参数是函数。当批处理达到最大大小或缓冲区持续时间超过时，将执行该功能。

名称	需求	描述
id	可选的	标识批处理者的唯一标识符
batch_max_size	可选的	每批的最大大小，默认为1000
inactive_timeout	可选的	如果不活动，将刷新缓冲区的最大时间（以秒为单位），默认值为5s
buffer_duration	可选的	必须先处理批次中最旧条目的最大期限（以秒为单位），默认是5
max_retry_count	可选的	从处理管道中移除之前的最大重试次数；默认为零
retry_delay	可选的	如果执行失败，应该延迟进程执行的秒数；默认为1

以下代码显示了如何使用批处理程序的示例。批处理处理器将要执行的功能作为第一个参数，将批处理配置作为第二个参数。

local bp = require("apisix.plugins.batch-processor")
local func_to_execute = function(entries)
            -- serialize to json array core.json.encode(entries)
            -- process/send data
            return true
       end

local config = {
    max_retry_count  = 2,
    buffer_duration  = 60,
    inactive_timeout  = 5,
    batch_max_size = 1,
    retry_delay  = 0
}


local batch_processor, err = bp:new(func_to_execute, config)

if batch_processor then
    batch_processor:push({hello='world'})
end

注意：请确保批处理的最大大小（条目数）在函数执行的范围内。刷新批处理的计时器基于“ inactive_timeout”配置运行。因此，为了获得最佳使用效果，保持“ inactive_timeout”小于“ buffer_duration”。

马建仓 AI 助手

尝试更多

代码解读

代码找茬

代码优化

Lua

1

https://gitee.com/liujunao153/apisix.git

git@gitee.com:liujunao153/apisix.git

liujunao153

apisix

Apache APISIX

master