当前位置:网站首页>解密函数计算异步任务能力之「任务的状态及生命周期管理」
解密函数计算异步任务能力之「任务的状态及生命周期管理」
2022-07-04 18:34:00 【InfoQ】
前言
任务的状态及生命周期的管理
任务的状态管理


- 用户触发一次任务后,任务入队,变更为 Enqueued 状态,并返回触发成功;
- 任务在函数计算后端服务中出队,任务变为 Dequeued 状态;
- 后端会检查任务配置。如果
- 配置了异步消息有效期功能,并且该消息出队时间与入队时间之差已超过有效期,则任务被丢弃,变更为 Expired 状态。任务终止;
- 任务对应的函数已被删除,或创建实例出现错误,则丢弃消息,任务变更为 Invalid 状态;
- 检查后任务正式进入 Running 状态。此时任务已触发实际的执行;
- 任务执行完成后,根据返回会变更为以下几个状态:
- Retrying:用户配置了重试次数(默认为 3),且任务执行失败,这时会进入重试中状态,之后会变更为 Running 状态;
- Failed:任务执行失败,且超过了重试次数。此时会将任务状态改为 Failed;
- Succeeded:任务执行成功。
- 如果在整个状态流转过程用户触发 Cancel,则任务会先变更为 Stopping 状态,并尝试停止任务执行。当任务停止执行成功后,任务进入 Stopped 状态。
任务运行时管理及生命周期

- 创建完成 -> 执行请求阶段:支持 Initializer 功能,支持初始化实例操作。用户可以配置诸如全局变量、连接池初始化等相关操作;
- 执行中 -> 执行完成后 Pause 实例:支持 PreFreeze 接口,支持在函数 Pause 实例前执行用户侧的自定义逻辑;
- 执行中 -> 外部 cancel:函数计算会强制 Restart 用户实例,在 Restart 前支持 PreStop 接口。用户可以配置优雅停止的相关逻辑,以便支持 Cancel 时的自定义行为;
- 完成后 Pause -> 销毁实例:当一段时间没有请求后,函数计算将销毁实例。此时会调用 PreStop 接口,用户可以配置销毁容器的行为(如关闭连接池等)。

任务的停止操作
import fc "github.com/aliyun/fc-go-sdk"
func CancelJob() {
stopInput := fc.NewStopStatefulAsyncInvocationInput("ServiceName", "FunctionName", "TaskUUID")
output, err := fcClient.StopStatefulAsyncInvocation(stopInput)
...
}
总结


边栏推荐
- Shell 編程核心技術《四》
- FTP, SFTP file transfer
- mysql中explain语句查询sql是否走索引,extra中的几种类型整理汇总
- Chrome开发工具:VMxxx文件是什么鬼
- Creation of JVM family objects
- 1009 Product of Polynomials(25 分)(PAT甲级)
- Lenovo explains in detail the green smart city digital twin platform for the first time to solve the difficulties of urban dual carbon upgrading
- 1005 spell it right (20 points) (pat a)
- Generate XML elements
- 【毕业季】绿蚁新醅酒,红泥小火炉。晚来天欲雪,能饮一杯无?
猜你喜欢

There are multiple divs in the large div, which are displayed on the same line. After overflow, scroll bars are generated without line breaks

BCG 使用之CBCGPProgressDlg进度条使用

Abc229 summary (connected component count of the longest continuous character graph in the interval)

实战模拟│JWT 登录认证

Stream流

"Only one trip", active recommendation and exploration of community installation and maintenance tasks

Cbcgpprogressdlg progress bar used by BCG

一文掌握数仓中auto analyze的使用

C语言-入门-基础-语法-流程控制(七)

Stream stream
随机推荐
abc229 总结(区间最长连续字符 图的联通分量计数)
Educational Codeforces Round 22 E. Army Creation
Jetpack Compose 教程
勾股数规律(任意三个数能够满足勾股定理需要满足的条件)
长城证券开户安全吗 买股票怎么开户
添加命名空间声明
To sort out messy header files, I use include what you use
BCG 使用之CBCGPProgressDlgCtrl进度条使用
Swagger突然发癫
Cbcgpprogressdlg progress bar used by BCG
PolyFit软件介绍
How test engineers "attack the city" (Part 2)
Kotlin basic data type
Shell 編程核心技術《四》
Shell programming core technology "three"
Niuke Xiaobai month race 7 who is the divine Archer
更强的 JsonPath 兼容性及性能测试之2022版(Snack3,Fastjson2,jayway.jsonpath)
Detailed explanation of the binary processing function threshold() of opencv
[QNX hypervisor 2.2 user manual]6.3.1 factory page and control page
Basic use of kotlin