跳转到主要内容

批处理框架

概述

MinIO 批处理框架允许使用 YAML 格式的作业定义文件(“batch file”)来创建、管理、监控和执行作业。 批处理作业直接在 MinIO 部署上运行,从而利用服务端处理能力,而不受运行 MinIO Client 的本地机器限制。

一个批处理文件定义一个作业任务。

启动后,MinIO 会开始处理该作业。 完成所需时间取决于部署可用的资源。

普通作业故障遵循定义中的重试次数上限。下一个 SILO 版本会区分授权拒绝与临时暂停,详见下文。

MinIO 批处理框架支持以下作业类型:

作业类型 说明
replicate 执行一次性复制流程,将数据从一个 MinIO 位置复制到另一个 MinIO 位置。
keyrotate 执行一次性流程,轮换对象上的 sse-s3 or sse-kms 加密密钥。
expire 对存储桶中的对象执行一次性立即过期操作。

SILO 下一个版本:授权与重试

SILO 创建作业时,把本地批处理操作绑定到经过认证的提交者。定义中的凭据用于远端连接,不会授予本地服务器权限;执行动作时再次检查当时的 IAM 权限。显式拒绝、凭据过期或撤销、提交者绑定发生变化,都会以 failureReason 结束作业。策略依赖后台作业无法取得的请求上下文时,也会拒绝相应动作。

IAM 尚未加载、策略资料暂时不可用、授权插件无法给出有效决定,都属于临时故障。提交阶段无法决定授权时返回 503。过期和密钥轮换作业通过 pausedReason 记录暂停,保留已完成进度,并在当前进程内通过有上限的指数退避与随机抖动重试。列举在开始时或流中途失败,也会暂停这两类作业。轮换选中的源位于正在迁移的池时先暂停,冲突解除后继续。每次重试重新解析当前身份与权限。等待或暂停的作业不是完成或失败报告,不会被终态报告清理器删除。管理员取消优先于队列和重试。

Push、Pull 和 Snowball 复制作业在必要的授权依赖或报告读取暂时不可用时(包括对象处理过程中发生的故障)也会通过 pausedReason 进入暂停,并在重试时从头重新扫描源端;详见批量复制。复制中途的其他故障仍遵循原有的有限对象重试,可能以失败结束。

启动发现作业时,清单列举或存储读取失败也会按有上限的退避重试。发现过程会记住已经入队的清单,避免后续扫描重新执行在等待期间已经结束的作业;取消状态会阻止旧扫描结果重新入队。已经不存在、格式损坏或版本不受支持的清单不会入队,后两类保留在磁盘上供检查。启动发现期间的存储故障恢复后,无需再次重启即可继续发现作业。

已完成作业在重启后仍保持完成,包括旧格式作业和完成后凭据过期或变更的作业。来自不记录提交者绑定的旧版本、且尚未完成的作业需要重新提交。新绑定定义和已授权进度报告采用旧执行器会拒绝的格式。这可以阻止旧程序接管这些记录,但不能保证混合版本集群安全:旧节点仍能接收和执行自己的旧格式作业。切换版本前停止提交,并排空或取消旧作业;仍有等待执行的授权作业时不要降级。

使用 mcli batch status(20261109)区分暂停、终态失败和仍有受保护工作未处理的完成结果。infraAdmin 仍有其他基础设施管理能力,这些作业检查不把该角色变成严格的数据隔离边界。

MinIO 批处理 CLI

mc batch 命令包括:

mc batch generate

mc batch generate 命令会为指定作业类型创建一个基础的 YAML 格式模板文件。

mc batch start

mc batch start 命令根据批处理作业 YAML 文件启动一个批处理作业。

mc batch list

mc batch list 命令会输出部署中当前正在进行的批处理作业列表。

mc batch status

mc batch status 命令会输出 MinIO 服务器上作业事件的汇总信息。

mc batch describe

mc batch describe 命令会输出指定作业 ID 的作业定义。

mc batch cancel

mc batch cancel 可停止正在进行的批处理作业。

mc batch 的访问权限

提交身份需要相应的管理动作权限,以及作业需要的本地 数据权限。定义中的凭据还必须具备远端操作所需的权限。下一个版本的具体规则见上文。

执行批处理作业的用户必须具有以下权限。 也可以通过阻止或限制对这些操作的访问,来限制用户使用这些功能:

admin:ListBatchJobs

授予用户查看当前正在处理的批处理作业的能力。

admin:DescribeBatchJobs

授予用户查看当前正在处理的批处理作业定义详情的能力。

admin:StartBatchJob

授予用户启动批处理作业的能力。 该作业还可能受到其用于访问源部署或目标部署的凭证进一步限制。

admin:CancelBatchJob

允许用户停止当前正在进行的批处理作业。

可以将这些操作中的任意一个单独分配给用户,也可以任意组合分配。

内置的 ConsoleAdmin 策略包含执行所有这些类型批处理作业操作所需的充分访问权限。

Local 部署

可通过向 mc batch 命令传递一个 alias,对特定部署运行批处理作业。 命令中指定的部署会在该批处理作业的上下文中成为 local 部署。

表格阅读