开源FaaS平台(四):Fission

本文涉及的产品
日志服务 SLS,月写入数据量 50GB 1个月
函数计算FC,每月15万CU 3个月
容器服务 Serverless 版 ACK Serverless,952元额度 多规格
简介: Kubernetes中文社区对Fission的描述是:Fission是一款基于Kubernetes的FaaS框架。通过Fission可以轻而易举地将函数发布成HTTP服务。它通过读取用户的源代码,抽象出容器镜像并执行。同时它帮助开发者们减轻了Kubernetes的学习负担,开发者无需了解太多Kubernetes也可以搭建出实用的服务。Fission可以与HTTP路由、Kubernetes Events和其他的事件触发器结合,所有这些函数都只有在运行的时候才会消耗CPU和内存。

Fission

Kubernetes中文社区对Fission的描述是:Fission是一款基于Kubernetes的FaaS框架。通过Fission可以轻而易举地将函数发布成HTTP服务。它通过读取用户的源代码,抽象出容器镜像并执行。同时它帮助开发者们减轻了Kubernetes的学习负担,开发者无需了解太多Kubernetes也可以搭建出实用的服务。Fission可以与HTTP路由、Kubernetes Events和其他的事件触发器结合,所有这些函数都只有在运行的时候才会消耗CPU和内存。Kubernetes提供了强大的弹性编排系统,并且拥有易于理解的后端API和不断发展壮大的社区。所以Fission将容器编排功能交给了Kubernetes,让自己专注于FaaS的特性。

在Gihub上面,是以这样的特性描述,对Fission进行描述:

  • Performance: 100msec cold start: Fission maintains a pool of "warm" containers that each contain a small dynamic loader. When a function is first called, i.e. "cold-started", a running container is chosen and the function is loaded. This pool is what makes Fission fast: cold-start latencies are typically about 100msec.
  • Kubernetes is the right place for Serverless: We're built on Kubernetes because we think any non-trivial app will use a combination of serverless functions and more conventional microservices, and Kubernetes is a great framework to bring these together seamlessly. Building on Kubernetes also means that anything you do for operations on your Kubernetes cluster — such as monitoring or log aggregation — also helps with ops on your Fission deployment.

可见,Fission在FaaS平台上面的两大特性或者说是优点:

  • 针对冷启动进行优化;
  • 基于Kubernetes进行部署,降低Kubernetes使用难度;

工作原理

Fission是一款基于Kubernetes的FaaS框架。通过Fission可以轻而易举地将函数发布成HTTP服务。它通过读取用户的源代码,抽象出容器镜像并执行。他整体结构也是依靠K8S来实现的:

在这个结构中,Fission主要包括了三个模块:

  • Controller:提供了针对 Fission 资源的增删改查操作接口,包括 Functions、Triggers、Environments、Kubernetes Event Watches 等。它是 Fission CLI 的主要交互对象。
  • Router:函数访问入口,同时也实现了 HTTP 触发器。它负责将用户请求以及各种事件源产生的事件转发至目标函数。
  • Executor:fission 包含 PoolManager 和 NewDeploy 两类执行器,它们控制着 Fission 函数的生命周期。

功能与策略

Executor模块

PoolManager

其中fission 包含 的PoolManager 和 NewDeploy 两类执行器,是有不同的作用和价值的。Poolmgr使用了池化技术,它通过为每个 Environment 维持了一定数量的通用 Pod 并在函数被触发时将 Pod 特化,大大降低了函数的冷启动的时间。同时,Poolmgr 会自动清理一段时间内未被访问的函数,减少闲置成本。

PoolManager执行器的基本流程:

1、使用 Fission CLI 向 Controller 发送请求,创建函数运行时需要的特定语言环境。

2、Poolmgr 定期同步 Environment 资源列表,定期时间是2S

3、Poolmgr 遍历 Environment 列表,使用 Deployment 为每个 Environment 创建一个通用 Pod 池,

4、使用 Fission CLI 向 Controller 发送创建函数的请求。此时,Controller 只是将函数源码等信息持久化存储,并未真正构建好可执行函数。

5、Router 接收到触发函数执行的请求,加载目标函数相关信息。

6、Router 向 Executor 发送请求获取函数访问入口

7、Poolmgr 从函数指定环境对应的通用 Pod 池里随机选择一个 Pod 作为函数执行的载体.通过更改 Pod 的标签让其从 Deployment 中“独立”出来,Kubernetes发现 Deployment 所管理 Pod 的实际副本数少于目标副本数后会对 Pod 进行补充,这样便实现了保持通用 pod 池中的 Pod 个数的目的。

8、特化处理被挑选出来的 Pod,这里需要先准备数据,包括Pod信息和用户的function等信息,并将信息交给Fetcher来处理。通过POST方法传入代码资源,整个过程的流程:

Fetcher:下载用户函数并将其放置在共享 Volume 里。

Env:用户函数运行的载体。当它成功加载共享 Volume 里的用户函数后,便可接收用户请求。详细过程:

  • 容器 Fetcher 接收到拉取用户函数的请求。
  • Fetcher 从 KubernetesCRD 或 Storagesvc 处获取用户函数。
  • Fetcher 将函数文件放置在共享的 Volume 里,如果文件被压缩还会负责解压。
  • 容器 Env 接收到加载用户函数的命令。
  • Env 从共享 Volume 中加载 Fetcher 为其准备好的用户函数。
  • 特化流程结束,容器 EEnv 开始处理用户请求。

9、为特化后的 Pod 创建 ClusterIP 类型的 Service

10、将函数的 Service 信息返回给 Router,Router 会将 ServiceUrl 缓存以避免频繁向 Executor 发送请求。

11、Router 使用返回的 ServiceUrl 访问函数

12、请求最终被路由至运行函数的 Pod。

13、如果该函数一段时间内未被访问会被自动清理,包括该函数的 Pod 和 Service

NewDeploy

Poolmgr 很好地平衡了函数的冷启动时间和闲置成本,但无法让函数根据度量指标自动伸缩。NewDeploy 执行器实现了函数 Pod 的自动伸缩和负载均衡。

NewDeploy的基本流程:

1、使用 fission CLI 向 Controller 发送请求,创建函数运行时需要的特定语言环境

2、使用 fission CLI 向 Controller 发送创建函数的请求。

3、Newdeploy 会注册一个 FuncController 持续监听针对 Function 的 ADD、UPDATE、DELETE 事件

4、Newdeploy 监听到了函数的 ADD 事件后,会根据 minScale 的取值判断是否立即为该函数创建相关资源

  • minScale > 0,则立即为该函数创建 Service、Deployment、HPA(Deployment 管理的 Pod 会特化)。
  • minScale <= 0,延迟到函数被真正触发时创建

5、Router 接收到触发函数执行的请求,加载目标函数相关信息

6、Router 向 NewDeploy 发送请求获取函数访问入口。如果函数所需资源已被创建,则直接返回访问入口。否则,创建好相关资源后再返回。

7、Router 使用返回的 ServiceUrl 访问函数

8、如果该函数一段时间内未被访问,函数的目标副本数会被调整成 minScale,但不会删除 Service、Deployment、HPA 等资源

上述两种方法,可以在Fn Creat的时候通过参数控制:

--executortype poolmgr

--executortype newdeploy

关于性能官方的描述为:

The executors allow you as a user to decide between latency and a small idle cost trade-off. Depending on the need you can choose one of the combinations which is optimal for your use case. In future, a more intelligent dispatch mechanism will enable more complex combinations of executors.

关于NewDeploy和Poolmgr的性能对比:

EXECUTOR TYPE

MIN SCALE

LATENCY

IDLE COST

Newdeploy

0

High

Very low - pods get cleaned up after idlle time

Newdeploy

>0

Low

Medium, Min Scale number of pods are always up

Poolmgr

0

Low

Low, pool of pods are always up

触发器

在触发器层面,Fission支持多样化的触发器,例如Synchronous Req/Rep类的有fission CLI、HTTP Trigger等,Job (Master/Worker)的有Time Trigger等,Async Message Queue类的有Message Queue Trigger(包括nats-streaming、 azure-storage-queue、 kafka等)和Kubernetes Watch Trigger。


弹性伸缩

在Fission官网,对自动扩缩容部分,有这样的描述:

The new deployment based executor provides autoscaling for functions based on CPU usage. In future custom metrics will be also supported for scaling the functions. You can set the initial and maximum CPU for a function and target CPU at which autoscaling will be triggered. Autoscaling is useful for workloads where you expect intermittant spikes in workloads. It also enables optimal the usage of resources to execute functions, by using a baseline capacity with minimum scale and ability to burst up to maximum scale based on spikes in demand.

可以看出,Fission的自动扩缩容部分,是通过CPU使用率来作为某一种标准,在上文分析过程中,可以明确Fission只有通过 NewDeploy 方式创建的函数才能利用 HPA 实现自动伸缩。

只能通过NewDeploy方法创建函数,且只有基于CPU使用率这一种指标(Kubeless支持CPU和QPS)过于局限。Fission的自动扩缩容部分使用的是Autoscaling/v1版本的 HPA API。以一个Demo为例,对其进行分析:

fission fn create --name hello --env python --code hello.py --executortype newdeploy --minmemory 64 --maxmemory 128 --minscale 1 --maxscale 6 --targetcpu 50

       该命令将创建一个名为 hello 的函数,运行该函数的 pod 会关联一个 HPA,该 HPA 会将 pod 数量控制在 1 到 6 之间,并通过增加或减少 pod 个数使得所有 pod 的平均 cpu 使用率维持在 50%。

日志

使用 DaemonSet 在集群中的每个工作节点上部署一个 Fluentd 实例用于采集当前机器上的容器日志。这里,Fluentd 容器将包含容器日志的宿主机目录/var/log/和/var/lib/docker/containers挂载进来,方便直接采集。Fluentd 将采集到的日志存储至 Influxdb 中。用户使用 fission CLI 查看函数日志。例如,使用命令fission function logs --name hello可以查看到函数 hello 产生的日志。


相关实践学习
【文生图】一键部署Stable Diffusion基于函数计算
本实验教你如何在函数计算FC上从零开始部署Stable Diffusion来进行AI绘画创作,开启AIGC盲盒。函数计算提供一定的免费额度供用户使用。本实验答疑钉钉群:29290019867
建立 Serverless 思维
本课程包括: Serverless 应用引擎的概念, 为开发者带来的实际价值, 以及让您了解常见的 Serverless 架构模式
目录
相关文章
|
23天前
|
存储 人工智能 JSON
基于函数计算FC一键部署ComfyUI绘画平台体验
【8月更文挑战第11天】基于函数计算FC一键部署ComfyUI绘画平台体验
54 1
|
2月前
|
弹性计算 分布式计算 Serverless
全托管一站式大规模数据处理和分析Serverless平台 | EMR Serverless Spark 评测
【7月更文挑战第6天】全托管一站式大规模数据处理和分析Serverless平台 | EMR Serverless Spark 评测
23681 42
|
1月前
|
Cloud Native Java Serverless
一键上天!如何将Spring PetClinic瞬间迁移到云端函数计算平台
【8月更文挑战第8天】在现代云原生开发中,将Spring应用迁移到Serverless环境正成为趋势。本文通过对比传统部署与函数计算,指导如何快速部署Spring PetClinic应用。传统部署需手动配置服务器和中间件,而函数计算则免除了这些步骤,仅需上传代码。首先,准备好Spring PetClinic源码或jar包;接着选择函数计算平台,本文以阿里云为例;随后对应用进行适配,并使用Maven构建部署包;登录阿里云控制台上传jar包并配置HTTP触发器;最后测试应用确保正常运行。
35 3
|
24天前
|
Kubernetes Serverless 调度
异步任务处理系统问题之在阿里云函数计算平台上用户提交异步任务的问题如何解决
异步任务处理系统问题之在阿里云函数计算平台上用户提交异步任务的问题如何解决
|
24天前
|
监控 Java Serverless
美团 Flink 大作业部署问题之想在Serverless平台上实时查看Spring Boot应用的日志要怎么操作
美团 Flink 大作业部署问题之想在Serverless平台上实时查看Spring Boot应用的日志要怎么操作
|
2月前
|
人工智能 前端开发 搜索推荐
详解基于百炼平台及函数计算快速上线网页AI助手
通过阿里云百炼平台,企业可在10分钟内为其网站添加智能客服系统,提升用户体验并降低成本。流程包括:创建大模型应用、配置参数(如温度系数以控制回复的随机性)、发布应用获取API密钥;使用函数计算快速搭建示例网站,并通过简单的代码更改启用AI助手功能;还可导入私有知识库增强助手的能力。前端基于NLUX开发,支持定制化需求如样式调整和历史会话管理。服务端代码提供了调用大模型获取答案的接口。借助百炼平台,企业能迅速部署即时且个性化的在线服务,适应数字化转型的需求。
|
30天前
|
运维 安全 Serverless
Serverless 平台问题之面临的挑战如何解决
全托管Serverless计算平台优势包括:免运维一站式应用管理降低运营成本;精益成本按实际用量计费;支持毫秒级弹性伸缩确保业务连续性;简化容器化部署流程;内置微服务治理功能;集成多种云服务便于Web应用管理;支持开源任务调度框架;基于标准容器接口易于集成第三方工具;提供安全隔离的应用环境;以及与云生态产品的自动集成提供全面解决方案。
47 0
|
2月前
|
Java Serverless API
云原生应用问题之将文档中的代码部署在函数计算平台上会提升用户体验如何解决
云原生应用问题之将文档中的代码部署在函数计算平台上会提升用户体验如何解决
33 0
|
4月前
|
运维 数据挖掘 Serverless
阿里云Elasticsearch Serverless助力某电商平台公司实现商品订单数据的实时写入查询
某电商平台公司采用阿里云Elasticsearch Serverless解决方案,实现商品、订单和其他关键信息的写入和查询的实时响应。
406 1
|
4月前
|
Serverless 云计算 Docker
SAE是全场景Serverless计算平台,深度融合微服务
【5月更文挑战第2天】SAE是全场景Serverless计算平台,深度融合微服务,提供SAE Job任务场景解决方案,具备便捷、节省、稳定、透明和省心的特点。而ECI是Serverless容器运行服务,结合云计算理念,仅需Docker镜像即可运行,支持细粒度资源计费,旨在降低成本和提升效率。SAE侧重应用管理和运营,ECI专注于优化容器资源使用。
54 0

热门文章

最新文章