配置指南

全局设置

数据库配置

GoBatch 需要数据库来存储任务和步骤的执行上下文,因此在运行任务之前必须设置数据库连接。

gobatch.SetDB(sqlDb)

事务管理器

对于分块处理步骤(Chunk Step),必须为 GoBatch 注册一个事务管理器实例。事务管理器接口定义如下:

type TransactionManager interface {
    BeginTx() (tx interface{}, err BatchError)
    Commit(tx interface{}) BatchError
    Rollback(tx interface{}) BatchError
}

如果已设置数据库但未设置事务管理器,GoBatch 会自动创建一个默认的事务管理器实例。

并发控制

GoBatch 使用内部任务池来运行作业和步骤,可以通过以下方法设置最大并发数:

// 设置最大运行作业数(默认值:10)
gobatch.SetMaxRunningJobs(100)

// 设置最大运行步骤数(默认值:1000)
gobatch.SetMaxRunningSteps(5000)

results matching ""

    No results matching ""