配置指南
全局设置
数据库配置
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)