阿里云 Serverless Kubernetes（ASK） 是阿里云推出的无服务器 Kubernetes 容器服务，底层基于 ECI(Elastic Container Instance)让您无需购买 ECS 节点就能直接创建安全隔离的容器应用。 ASK 通过了 Kubernetes 的一致性测试，给您提供了完全兼容社区 Kubernetes 的使用体验。
Knative 是一款基于 Kubernetes 的开源 Serverless 应用编排框架，其目标是制定云原生、跨平台的Serverless应用编排标准。阿里云 Knative 基于 ASK 之上，在完全兼容社区 Knaitve 的同时对 FC、ECI 工作负载进行统一应用编排，支持事件驱动、自动d性，为您提供统一的 Serverless 应用编程模型。
架构接下来我们通过一个d幕服务 demo 进行介绍。该 demo 主要包括 HomePage、事件驱动、消息处理这 3 部分。
HomePage 主要用于发送和接收d幕。事件驱动用来接收事件，并进行事件过滤、流转。消息处理，用于处理d幕消息。其中 HomePage、消息处理通过 Knative Serving 部署分别到 FC、ECI，事件驱动通过 Knative Eventing 部署到ECI。
d幕服务 demo 主要流程如图，用户通过前端发送d幕消息到 HomePage，HomePage 接着将d幕发送到 Kafka，事件驱动接收d幕消息，然后路由到消息处理进行加工，待d幕加工完之后，将d幕结果发送到表格存储中，最后前端获取d幕结果在页面展示。
接下来我们开始部署该d幕服务 demo, *** 作包括以下内容：
首先部署消息处理，然后部署事件驱动，接着部署 HomePage，待部署完成之后进行d幕服务访问
第一步：部署消息处理
该服务用于接收事件驱动发送的d幕请求，并根据请求数进行自动扩缩容，待d幕消息处理完成之后将结果发送到表格存储。部署之前，我们先确认当前无工作负载，以便观察部署之后的结果。
- 选择 ask 集群
- 在集群管理页左侧导航栏中，选择工作负载> 无状态。选择 default命名空间，确认当前无工作负载
接着通过 Knative 把d消息处理部署到 ECI 类型工作负载。这里我们通过yaml的方式进行部署，yaml内容如下：
apiVersion: serving.knative.dev/v1
kind: Service
metadata:
name: test-barrage-process
spec:
template:
metadata:
annotations:
autoscaling.knative.dev/maxScale: "100"
autoscaling.knative.dev/minScale: "0"
k8s.aliyun.com/eci-image-snapshot-id: imc-uf636kjjx8xr4e75npex
labels:
danmu.role: "manager"
spec:
containerConcurrency: 2
serviceAccountName: barrage-install-sa
containers:
- args:
- /manager
env:
- name: OTS_ENDPOINT
value: https://barrage.cn-hangzhou.tablestore.aliyuncs.com
- name: TABLE_NAME
value: barrage
- name: OTS_INSTANCENAME
value: barrage
- name: OTS_KEYID
value: xxx
- name: OTS_SECRET
value: xxx
- name: POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: ROLE
value: manager
- name: POD_NAMESPACE
valueFrom:
fieldRef:
fieldPath: metadata.namespace
- name: TRACE_NAME
value: "process"
- name: PARENT_SPAN
value: "barrage-sender"
- name: SUB_SPAN
value: "process"
- name: TRACING
value: "http://tracing-analysis-dc-sh.aliyuncs.com/adapt_g2it2kg78n@5cf06035aec2eb9_g2it2kg78n@53df7ad2afe8301/api/traces"
image: registry-vpc.cn-shanghai.aliyuncs.com/knative-sample/barrage-manager:forrester-yuanyi_4cd77c84-20210618215458
name: user-container
ports:
- containerPort: 8000
name: http1
主要参数说明：
- minScale和maxScale：表示服务配置的最小和最大Pod数量
- containerConcurrency：表示配置的Pod最大请求并发数
- OTS_ENDPOINT：表示配置的表格存储访问地址
- TRACING：表示配置的调用连地址
那么接下来我们部署该服务。
- 在集群管理页左侧导航栏中，选择应用 > Knative。
- 在服务管理页签右上角，单击【使用模版创建】。选择default 命名空间，将上面的 yaml 内容粘贴到模版，点击创建。
第二步：部署事件驱动
事件驱动用于接收事件并进行事件流过滤、流转。这里我们使用 Kafka 事件源作为事件驱动，用于从 Kafka 接收d幕消息，然后把d幕路由到消息处理。我们通过yaml的方式进行部署， yaml内容如下：
apiVersion: sources.knative.dev/v1alpha1
kind: KafkaSource
metadata:
annotations:
k8s.aliyun.com/req-timeout: "60"
k8s.aliyun.com/retry-count: "5"
k8s.aliyun.com/retry-interval: "2"
name: barrage
namespace: default
spec:
bootstrapServers: 192.168.42.205:9092,192.168.42.204:9092,192.168.42.203:9092
consumerGroup: barrage-info-consumer
sink:
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: test-barrage-process
namespace: default
topics: barrage-info
主要参数说明：
- kafka配置包括：kafka服务地址 ，d幕消息 topics 以及消费组 consumerGroup
- 路由的目标消息处理：test-barrage-process
那么接下来我们部署该服务。
- 在集群管理页左侧导航栏中，选择应用 > Knative。
- 在服务管理页签右上角，单击【使用模版创建】。选择default 命名空间，将上面的 yaml 内容粘贴到模版，点击创建。
以上消息处理和事件驱动都已部署完成，我们来验证一下。
(在集群管理页左侧导航栏中，选择工作负载 > 容器组)
在容器组中，可以看到消息处理以及 Kafka 事件源实例都已 running
第三步：部署HomePage
该服务用于接收前端d幕消息，并将d幕消息发送到 Kafka，同时从表格存储中接收d幕结果。这里通过 Knative 函数方式部署之后，会自动在FC中创建服务、函数、自定义域名。 *** 作之前我们先确认FC中无d幕服务、函数以及自定义域名。
- 登录FC控制台
- 在顶部菜单栏，选择地域（上海）。
打开服务及函数页面，确认无d幕服务及函数
- 在左侧导航栏中，单击自定义域名，确认无域名信息。
打开自定义域名页面，确认无自定义域名
接下来我们通过 Knative 把HomePage部署到FC类型工作负载。这里我们通过yaml的方式进行部署， yaml内容如下：
apiVersion: serving.knative.dev/v1
kind: Service
metadata:
name: demo-barrage
annotations:
workload.serving.knative.aliyun.com/class: "fc"
spec:
template:
metadata:
annotations:
fc.revision.serving.knative.aliyun.com/code-space: "image"
fc.revision.serving.knative.aliyun.com/role-arm: "acs:ram::xxxx:role/knative-fc"
fc.revision.serving.knative.aliyun.com/domain: '{"domain":"barrage.demo.knative.top","path":"/*"}'
spec:
containers:
- image: registry.cn-shanghai.aliyuncs.com/knative-sample/barrage-main:forrester-yuanyi_4cd77c84-20210618214527
env:
- name: OTS_ENDPOINT
value: https://barrage.cn-hangzhou.ots.aliyuncs.com
- name: TABLE_NAME
value: barrage
- name: OTS_INSTANCENAME
value: barrage
- name: OTS_KEYID
value: xxx
- name: OTS_SECRET
value: xxx
- name: KAFKA_SERVER
value: "106.15.11.179:9093,47.100.131.71:9093,47.102.44.91:9093"
- name: KAFKA_USER
value: "alikafka_pre-cn-xxx"
- name: KAFKA_PWD
value: "xxx"
- name: KAFKA_TOPIC
value: "barrage-info"
- name: TRACING
value: "http://tracing-analysis-dc-sh.aliyuncs.com/adapt_g2it2kg78n@5cf06035aec2eb9_g2it2kg78n@53df7ad2afe8301/api/traces"
- name: TRACE_NAME1
value: "sender"
- name: TRACE_NAME2
value: "receiver"
- name: TRACE_NAME3
value: "result"
- name: PARENT_SPAN
value: "barrage-sender"
- name: SUB_SPAN1
value: "sender"
- name: SUB_SPAN2
value: "result"
主要参数说明：
- fc 相关参数配置包括： 部署fc类型的工作负载、通过镜像方式部署，并指定访问域名为： barrage.demo.knative.top
- 配置表格存储访问地址: OTS_ENDPOINT
- kafka 相关参数配置：kafka服务地址、d幕消息 topic
- 调用连地址配置：TRACING
那么我们来部署该服务。
- 登录容器服务管理控制台。
- 在集群管理页左侧导航栏中，选择应用 > Knative。
- 在服务管理页签右上角，单击【使用模版创建】。选择default 命名空间，将上面的 yaml 内容粘贴到模版，点击创建。
部署完成之后，我们在函数计算控制台验证一下。
- 登录函数计算控制台。
- 在顶部菜单栏，选择地域。
- 在左侧导航栏中，单击服务及函数，选择可以看到d幕服务已经部署完成
打开服务及函数页面，可以看到HomePage已经部署完成。
- 在左侧导航栏中，单击自定义域名。
打开自定义域名页面，可以看到自动创建出来了我们配置的域名。
第四步：服务访问
以上服务都已部署完成，接着我们通过自定义域名进行服务访问。
http://barrage.demo.knative.top
接下来我们发送d幕，这里可以自定义设置需要发送的d幕消息，并发数以及持续时间。这里我们使用默认配置进行发送。
设置Message、Concurrency以及Duration，点击【Send】
我们可以看到不断有d幕消息展示出来。
小结阿里云 Knative 在 Serverless Kubernetes 之上，提供了面向容器+函数的统一编程模型，给你带来统一的Serverless 应用编程模型。欢迎有兴趣的同学一起交流。
原文链接
本文为阿里云原创内容，未经允许不得转载。
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）