楼盘建设信息网站,wordpress 取消标志,站长之家模板,旅游电子商务网站建设与研究简介#xff1a; 阿里云 Knative 基于 ASK 之上#xff0c;在完全兼容社区 Knaitve 的同时对 FC、ECI 工作负载进行统一应用编排#xff0c;支持事件驱动、自动弹性#xff0c;为您提供统一的 Serverless 应用编程模型。
背景
阿里云 Serverless Kubernetes#xff08;A…简介 阿里云 Knative 基于 ASK 之上在完全兼容社区 Knaitve 的同时对 FC、ECI 工作负载进行统一应用编排支持事件驱动、自动弹性为您提供统一的 Serverless 应用编程模型。
背景
阿里云 Serverless KubernetesASK 是阿里云推出的无服务器 Kubernetes 容器服务底层基于 ECI(Elastic Container Instance)让您无需购买 ECS 节点就能直接创建安全隔离的容器应用。 ASK 通过了 Kubernetes 的一致性测试给您提供了完全兼容社区 Kubernetes 的使用体验。
Knative 是一款基于 Kubernetes 的开源 Serverless 应用编排框架其目标是制定云原生、跨平台的Serverless应用编排标准。阿里云 Knative 基于 ASK 之上在完全兼容社区 Knaitve 的同时对 FC、ECI 工作负载进行统一应用编排支持事件驱动、自动弹性为您提供统一的 Serverless 应用编程模型。
架构
接下来我们通过一个弹幕服务 demo 进行介绍。该 demo 主要包括 HomePage、事件驱动、消息处理这 3 部分。
HomePage 主要用于发送和接收弹幕。事件驱动用来接收事件并进行事件过滤、流转。消息处理用于处理弹幕消息。其中 HomePage、消息处理通过 Knative Serving 部署分别到 FC、ECI事件驱动通过 Knative Eventing 部署到ECI。
弹幕服务 demo 主要流程如图用户通过前端发送弹幕消息到 HomePageHomePage 接着将弹幕发送到 Kafka事件驱动接收弹幕消息然后路由到消息处理进行加工待弹幕加工完之后将弹幕结果发送到表格存储中最后前端获取弹幕结果在页面展示。 接下来我们开始部署该弹幕服务 demo, 操作包括以下内容
首先部署消息处理然后部署事件驱动接着部署 HomePage待部署完成之后进行弹幕服务访问
第一步部署消息处理
该服务用于接收事件驱动发送的弹幕请求并根据请求数进行自动扩缩容待弹幕消息处理完成之后将结果发送到表格存储。部署之前我们先确认当前无工作负载以便观察部署之后的结果。
选择 ask 集群在集群管理页左侧导航栏中选择工作负载 无状态。选择 default命名空间确认当前无工作负载接着通过 Knative 把弹消息处理部署到 ECI 类型工作负载。这里我们通过yaml的方式进行部署yaml内容如下
apiVersion: serving.knative.dev/v1
kind: Service
metadata:name: test-barrage-process
spec:template:metadata:annotations:autoscaling.knative.dev/maxScale: 100autoscaling.knative.dev/minScale: 0k8s.aliyun.com/eci-image-snapshot-id: imc-uf636kjjx8xr4e75npexlabels:danmu.role: managerspec:containerConcurrency: 2serviceAccountName: barrage-install-sacontainers:- args:- /managerenv:- name: OTS_ENDPOINTvalue: https://barrage.cn-hangzhou.tablestore.aliyuncs.com- name: TABLE_NAMEvalue: barrage- name: OTS_INSTANCENAMEvalue: barrage- name: OTS_KEYIDvalue: xxx- name: OTS_SECRETvalue: xxx- name: POD_NAMEvalueFrom:fieldRef:fieldPath: metadata.name- name: ROLEvalue: manager- name: POD_NAMESPACEvalueFrom:fieldRef:fieldPath: metadata.namespace- name: TRACE_NAMEvalue: process- name: PARENT_SPANvalue: barrage-sender- name: SUB_SPANvalue: process- name: TRACINGvalue: http://tracing-analysis-dc-sh.aliyuncs.com/adapt_g2it2kg78n5cf06035aec2eb9_g2it2kg78n53df7ad2afe8301/api/tracesimage: registry-vpc.cn-shanghai.aliyuncs.com/knative-sample/barrage-manager:forrester-yuanyi_4cd77c84-20210618215458name: user-containerports:- containerPort: 8000name: http1
主要参数说明
minScale和maxScale表示服务配置的最小和最大Pod数量containerConcurrency表示配置的Pod最大请求并发数OTS_ENDPOINT表示配置的表格存储访问地址TRACING表示配置的调用连地址
那么接下来我们部署该服务。
在集群管理页左侧导航栏中选择应用 Knative。在服务管理页签右上角单击【使用模版创建】。选择default 命名空间将上面的 yaml 内容粘贴到模版点击创建。
第二步部署事件驱动
事件驱动用于接收事件并进行事件流过滤、流转。这里我们使用 Kafka 事件源作为事件驱动用于从 Kafka 接收弹幕消息然后把弹幕路由到消息处理。我们通过yaml的方式进行部署 yaml内容如下
apiVersion: sources.knative.dev/v1alpha1
kind: KafkaSource
metadata:annotations:k8s.aliyun.com/req-timeout: 60k8s.aliyun.com/retry-count: 5k8s.aliyun.com/retry-interval: 2name: barragenamespace: default
spec:bootstrapServers: 192.168.42.205:9092,192.168.42.204:9092,192.168.42.203:9092consumerGroup: barrage-info-consumersink:ref:apiVersion: serving.knative.dev/v1kind: Servicename: test-barrage-processnamespace: defaulttopics: barrage-info
主要参数说明
kafka配置包括kafka服务地址 弹幕消息 topics 以及消费组 consumerGroup路由的目标消息处理test-barrage-process
那么接下来我们部署该服务。
在集群管理页左侧导航栏中选择应用 Knative。在服务管理页签右上角单击【使用模版创建】。选择default 命名空间将上面的 yaml 内容粘贴到模版点击创建。
以上消息处理和事件驱动都已部署完成我们来验证一下。
(在集群管理页左侧导航栏中选择工作负载 容器组)
在容器组中可以看到消息处理以及 Kafka 事件源实例都已 running 第三步部署HomePage
该服务用于接收前端弹幕消息并将弹幕消息发送到 Kafka同时从表格存储中接收弹幕结果。这里通过 Knative 函数方式部署之后会自动在FC中创建服务、函数、自定义域名。操作之前我们先确认FC中无弹幕服务、函数以及自定义域名。
登录FC控制台在顶部菜单栏选择地域上海。
打开服务及函数页面确认无弹幕服务及函数 在左侧导航栏中单击自定义域名确认无域名信息。
打开自定义域名页面确认无自定义域名 接下来我们通过 Knative 把HomePage部署到FC类型工作负载。这里我们通过yaml的方式进行部署 yaml内容如下 apiVersion: serving.knative.dev/v1
kind: Service
metadata:name: demo-barrageannotations:workload.serving.knative.aliyun.com/class: fc
spec:template:metadata:annotations:fc.revision.serving.knative.aliyun.com/code-space: imagefc.revision.serving.knative.aliyun.com/role-arm: acs:ram::xxxx:role/knative-fcfc.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-20210618214527env:- name: OTS_ENDPOINTvalue: https://barrage.cn-hangzhou.ots.aliyuncs.com- name: TABLE_NAMEvalue: barrage- name: OTS_INSTANCENAMEvalue: barrage- name: OTS_KEYIDvalue: xxx- name: OTS_SECRETvalue: xxx- name: KAFKA_SERVERvalue: 106.15.11.179:9093,47.100.131.71:9093,47.102.44.91:9093- name: KAFKA_USERvalue: alikafka_pre-cn-xxx- name: KAFKA_PWDvalue: xxx- name: KAFKA_TOPICvalue: barrage-info- name: TRACINGvalue: http://tracing-analysis-dc-sh.aliyuncs.com/adapt_g2it2kg78n5cf06035aec2eb9_g2it2kg78n53df7ad2afe8301/api/traces- name: TRACE_NAME1value: sender- name: TRACE_NAME2value: receiver- name: TRACE_NAME3value: result- name: PARENT_SPANvalue: barrage-sender- name: SUB_SPAN1value: sender- name: SUB_SPAN2value: result
主要参数说明
fc 相关参数配置包括 部署fc类型的工作负载、通过镜像方式部署并指定访问域名为 barrage.demo.knative.top配置表格存储访问地址: OTS_ENDPOINTkafka 相关参数配置kafka服务地址、弹幕消息 topic调用连地址配置TRACING
那么我们来部署该服务。
登录容器服务管理控制台。在集群管理页左侧导航栏中选择应用 Knative。在服务管理页签右上角单击【使用模版创建】。选择default 命名空间将上面的 yaml 内容粘贴到模版点击创建。
部署完成之后我们在函数计算控制台验证一下。
登录函数计算控制台。在顶部菜单栏选择地域。在左侧导航栏中单击服务及函数选择可以看到弹幕服务已经部署完成
打开服务及函数页面可以看到HomePage已经部署完成。 在左侧导航栏中单击自定义域名。
打开自定义域名页面可以看到自动创建出来了我们配置的域名。 第四步服务访问
以上服务都已部署完成接着我们通过自定义域名进行服务访问。http://barrage.demo.knative.top
接下来我们发送弹幕这里可以自定义设置需要发送的弹幕消息并发数以及持续时间。这里我们使用默认配置进行发送。
设置Message、Concurrency以及Duration点击【Send】 我们可以看到不断有弹幕消息展示出来。 小结
阿里云 Knative 在 Serverless Kubernetes 之上提供了面向容器函数的统一编程模型给你带来统一的Serverless 应用编程模型。欢迎有兴趣的同学一起交流。
原文链接 本文为阿里云原创内容未经允许不得转载。
