详解异步任务:任务的状态及生命周期管理
共 2383字,需浏览 5分钟
·
2022-06-20 13:59
前言
任务的状态
1、用户触发一次任务后,任务入队,变更为 Enqueued 状态,并返回触发成功;
2、任务在函数计算后端服务中出队,任务变为 Dequeued 状态;
3、后端会检查任务配置。如果:
配置了异步消息有效期功能,并且该消息出队时间与入队时间之差已超过有效期,则任务被丢弃,变更为 Expired 状态。任务终止;
任务对应的函数已被删除,或创建实例出现错误,则丢弃消息,任务变更为 Invalid 状态;
4、检查后任务正式进入 Running 状态。此时任务已触发实际的执行;
5、任务执行完成后,根据返回会变更为以下几个状态:
Retrying:用户配置了重试次数(默认为 3),且任务执行失败,这时会进入重试中状态,之后会变更为 Running 状态;
Failed:任务执行失败,且超过了重试次数。此时会将任务状态改为 Failed;
Succeeded:任务执行成功。
6、如果在整个状态流转过程用户触发 Cancel,则任务会先变更为 Stopping 状态,并尝试停止任务执行。当任务停止执行成功后,任务进入 Stopped 状态。
当任务状态进入 Running 后,任务的实际执行便已交给函数计算的运行时。
在安全性方面,函数计算会按照 VM 对不同账号进行隔离,同一个账号下的函数可能运行于同一个 VM 中。VM 内有一个负责管理容器的客户端,来实际触发函数的执行,并收集执行结果。
用户的运行实例有几个不同的状态:
函数计算对上述所有实例状态变化的过程均提供接口,支持用户侧配置相应的逻辑。
1、创建完成 -> 执行请求阶段:支持 Initializer 功能,支持初始化实例操作。用户可以配置诸如全局变量、连接池初始化等相关操作;
2、执行中 -> 执行完成后 Pause 实例:支持 PreFreeze 接口,支持在函数 Pause 实例前执行用户侧的自定义逻辑;
3、执行中 -> 外部 cancel:函数计算会强制 Restart 用户实例,在 Restart 前支持 PreStop 接口。用户可以配置优雅停止的相关逻辑,以便支持 Cancel 时的自定义行为;
4、完成后 Pause -> 销毁实例:当一段时间没有请求后,函数计算将销毁实例。此时会调用 PreStop 接口,用户可以配置销毁容器的行为(如关闭连接池等)。
目前阶段函数计算支持了停止单一任务的操作。
当用户操作停止时,支持配置 PreStop 接口,在停止前进行一系列的资源回收工作。停止操作用户可以使用 SDK 或控制台来进行调用。以 Go 语言为例,停止一次执行的伪代码如下所示:
import fc "github.com/aliyun/fc-go-sdk"
func CancelJob() {
stopInput := fc.NewStopStatefulAsyncInvocationInput("ServiceName", "FunctionName", "TaskUUID")
output, err := fcClient.StopStatefulAsyncInvocation(stopInput)
...
}
总结