写点什么

Knative 基本功能深入剖析:Knative Eventing 之 Sequence 介绍

  • 2019-09-04
  • 本文字数:7181 字

    阅读完需:约 24 分钟

Knative 基本功能深入剖析:Knative Eventing 之 Sequence 介绍

在实际的开发中我们经常会遇到将一条数据需要经过多次处理的场景,称为 Pipeline。那么在 Knative 中是否也提供这样的能力呢?其实从 Knative Eventing 0.7 版本开始,就提供了 Sequence CRD 资源,用于事件处理 Pipeline。本篇文章中,阿里云容器平台高级开发工程师元毅将为大家详细介绍 Sequence 的定义及在 Knative Eventing 中提供的 4 种使用场景。

Sequence 定义

首先来看一下 Sequence Spec 定义:


apiVersion: messaging.knative.dev/v1alpha1kind: Sequencemetadata:  name: testspec:  channelTemplate:    apiVersion: messaging.knative.dev/v1alpha1    kind: InMemoryChannel  steps:    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: test  reply:    kind: Broker    apiVersion: eventing.knative.dev/v1alpha1    name: test
复制代码


Sequence Spec 包括 3 个部分:


  1. steps: 在 step 中定义了按照顺序执行的服务,每个服务会对应创建 Subscription;

  2. channelTemplate:指定了使用具体的那个 Channel;

  3. reply:(可选)定义了将最后一个 step 服务结果转发到的目标服务。


Sequence 都是适合哪些具体应用场景呢?我们上面也提到了事件处理的 Pipeline。那么在实际场景应用中究竟以什么样的形式体现呢? 现在我们揭晓一下 Sequence 在 Knative Eventing 中提供的如下 4 种使用场景:


  • 直接访问 Service;

  • 面向事件处理;

  • 级联 Sequence;

  • 面向 Broker/Trigger。

直接访问 Service 场景

事件源产生的事件直接发送给 Sequence 服务, Sequence 接收到事件之后顺序调用 Service 服务对事件进行处理:


创建 Knative Service

这里我们创建 3 个 Knative Service 用于事件处理。每个 Service 接收到事件之后会打印当前的事件处理信息。


apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata:  name: firstspec:  template:    spec:      containers:        - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700          env:            - name: STEP              value: "0"
---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: secondspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "1"---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: thirdspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "2"---
复制代码


创建 Sequence

创建顺序调用 first->second->third Service 的 Sequence。


apiVersion: messaging.knative.dev/v1alpha1kind: Sequencemetadata:  name: sequencespec:  channelTemplate:    apiVersion: messaging.knative.dev/v1alpha1    kind: InMemoryChannel  steps:    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: first    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: second    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: third
复制代码


创建数据源

创建 CronJobSource 数据源,每隔 1 分钟发送一条事件消息 {"message": "Hello world!"} 到 Sequence 服务。


apiVersion: sources.eventing.knative.dev/v1alpha1kind: CronJobSourcemetadata:  name: cronjob-sourcespec:  schedule: "*/1 * * * *"  data: '{"message": "Hello world!"}'  sink:    apiVersion: messaging.knative.dev/v1alpha1    kind: Sequence    name: sequence
复制代码


示例结果




面向事件处理场景

事件源产生的事件直接发送给 Sequence 服务, Sequence 接收到事件之后顺序调用 Service 服务对事件进行处理,处理之后的最终结果会调用 event-display Service 显示:


创建 Knative Service

同上创建 3 个 Knative Service 用于事件处理:


apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata:  name: firstspec:  template:    spec:      containers:        - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700          env:            - name: STEP              value: "0"
---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: secondspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "1"---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: thirdspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "2"---
复制代码

创建 Sequence

创建顺序调用 first->second->third Service 的 Sequence,将处理结果通过 reply 发送给 event-display


apiVersion: messaging.knative.dev/v1alpha1kind: Sequencemetadata:  name: sequencespec:  channelTemplate:    apiVersion: messaging.knative.dev/v1alpha1    kind: InMemoryChannel  steps:    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: first    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: second    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: third  reply:    kind: Service    apiVersion: serving.knative.dev/v1alpha1    name: event-display
复制代码

创建结果显示 Service

创建 event-display Service, 用于接收最终的结果信息。


apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata:  name: event-displayspec:  template:    spec:      containers:        - image: registry.cn-hangzhou.aliyuncs.com/knative-release/event_display:bf45b3eb1e7fc4cb63d6a5a6416cf696295484a7662e0cf9ccdf5c080542c21d
复制代码

创建数据源

创建 CronJobSource 数据源,每隔 1 分钟发送一条事件消息 {"message": "Hello world!"} 到 Sequence 服务。


apiVersion: sources.eventing.knative.dev/v1alpha1kind: CronJobSourcemetadata:  name: cronjob-sourcespec:  schedule: "*/1 * * * *"  data: '{"message": "Hello world!"}'  sink:    apiVersion: messaging.knative.dev/v1alpha1    kind: Sequence    name: sequence
复制代码

示例结果


级联 Sequence 场景

Sequence 更高级的地方还在于支持级联处理: Sequence By Sequence,这样可以进行多次 Sequence 处理,满足复杂事件处理场景需求。


创建 Knative Service

创建 6 个 Knative Service 用于事件处理, 前 3 个用于第 1 个 Sequence,后 3 个用于第 2 个 Sequence。


apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata:  name: firstspec:  template:    spec:      containers:        - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700          env:            - name: STEP              value: "0"
---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: secondspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "1"---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: thirdspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "2"---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: fourthspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "3"
---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: fifthspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "4"---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: sixthspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "5"---
复制代码

创建第 1 个 Sequence

使用 first->second->third Service 用于第 1 个 Sequence 调用处理,将执行结果发送给第 2 个 Sequence。


apiVersion: messaging.knative.dev/v1alpha1kind: Sequencemetadata:  name: first-sequencespec:  channelTemplate:    apiVersion: messaging.knative.dev/v1alpha1    kind: InMemoryChannel  steps:    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: first    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: second    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: third  reply:    kind: Sequence    apiVersion: messaging.knative.dev/v1alpha1    name: second-sequence
复制代码

创建第 2 个 Sequence

使用 fourth->fifth->sixth Service 用于第 2 个 Sequence 调用处理,将执行结果发送给 event-display


apiVersion: messaging.knative.dev/v1alpha1kind: Sequencemetadata:  name: second-sequencespec:  channelTemplate:    apiVersion: messaging.knative.dev/v1alpha1    kind: InMemoryChannel  steps:    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: fourth    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: fifth    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: sixth  reply:    kind: Service    apiVersion: serving.knative.dev/v1alpha1    name: event-display
复制代码

创建结果显示 Service

apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata:  name: event-displayspec:  template:    spec:      containerers:        - image: registry.cn-hangzhou.aliyuncs.com/knative-release/event_display:bf45b3eb1e7fc4cb63d6a5a6416cf696295484a7662e0cf9ccdf5c080542c21d
复制代码

创建数据源指向第 1 个 Sequence

apiVersion: sources.eventing.knative.dev/v1alpha1kind: CronJobSourcemetadata:  name: cronjob-sourcespec:  schedule: "*/1 * * * *"  data: '{"message": "Hello world!"}'  sink:    apiVersion: messaging.knative.dev/v1alpha1    kind: Sequence    name: first-sequence
复制代码

示例结果


Broker/Trigger 场景

事件源 cronjobsource 向 Broker 发送事件,通过 Trigger 将这些事件发送到由 3 个 Service 调用的 Sequence 中。Sequence 处理完之后将结果事件发送给 Broker,并最终由另一个 Trigger 发送给 event-display Service 显示事件结果:


创建 Knative Service

同上创建 3 个 Knative Service,用于 Sequence 中服务处理。


apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata:  name: firstspec:  template:    spec:      containers:      - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700        env:        - name: STEP          value: "0"
---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: secondspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "1"---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata: name: thirdspec: template: spec: containers: - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700 env: - name: STEP value: "2"
---
复制代码

创建 Sequence

创建 Sequence,这里依次顺序执行 first->second->third 这 3 个服务。将最终处理的结果发送到 broker-test 中。


apiVersion: messaging.knative.dev/v1alpha1kind: Sequencemetadata:  name: sequencespec:  channelTemplate:    apiVersion: messaging.knative.dev/v1alpha1    kind: InMemoryChannel  steps:    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: first    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: second    - ref:        apiVersion: serving.knative.dev/v1alpha1        kind: Service        name: third  reply:    kind: Broker    apiVersion: eventing.knative.dev/v1alpha1    name: default
复制代码

创建事件源指向 Broker

创建 CronjobSource,它将每隔 1 分钟发送一条 {"message": "Hello world!"} 消息到 broker-test 中。


apiVersion: sources.eventing.knative.dev/v1alpha1kind: CronJobSourcemetadata:  name: cronjob-sourcespec:  schedule: "*/1 * * * *"  data: '{"message": "Hello world!"}'  sink:    apiVersion: eventing.knative.dev/v1alpha1    kind: Broker    name: default
复制代码

创建 Broker

创建默认 Broker:


kubectl label namespace default knative-eventing-injection=enabled
复制代码

创建 Trigger,指向 Sequence

创建订阅事件类型为 dev.knative.cronjob.event 的 Trigger, 用于 Sequence 进行消费处理。


apiVersion: eventing.knative.dev/v1alpha1kind: Triggermetadata:  name: sequence-triggerspec:  filter:    sourceAndType:      type: dev.knative.cronjob.event  subscriber:    ref:      apiVersion: messaging.knative.dev/v1alpha1      kind: Sequence      name: sequence
复制代码

创建结果订阅 Trigger

创建订阅 samples.http.mod3 的事件类型 Trigger,将 Sequence 执行的结果发送给 event-display Service 进行显示。


apiVersion: eventing.knative.dev/v1alpha1kind: Triggermetadata:  name: display-triggerspec:  filter:    sourceAndType:      type: samples.http.mod3  subscriber:    ref:      apiVersion: serving.knative.dev/v1alpha1      kind: Service      name: event-display---apiVersion: serving.knative.dev/v1alpha1kind: Servicemetadata:  name: event-displayspec:  template:    spec:      containers:        - image: registry.cn-hangzhou.aliyuncs.com/knative-release/event_display:bf45b3eb1e7fc4cb63d6a5a6416cf696295484a7662e0cf9ccdf5c080542c21d---
复制代码

示例结果


小结

以上介绍了什么是 Sequence, 以及基于 Sequence 的 4 种使用场景,我们可以根据实际需求选择不同的使用场景,从而实现事件处理 Pipeline。这对于需要多步骤处理事件的场景尤为适合。


作者介绍:


元毅,阿里云容器平台高级开发工程师,负责阿里云容器平台 Knative 相关工作。


相关文章:


《初识 Knative:跨平台的 Serverless 编排框架》


《Knative 初体验:Serving Hello World》


《Knative 初体验:Eventing Hello World》


《Knative 初体验:Build Hello World》


《Knative 初体验:CI/CD 极速入门》


《Knative 基本功能深入剖析:Knative Serving 的流量灰度和版本管理》


《Knative 基本功能深入剖析:Knative Serving 自动扩缩容 Autoscaler》


《Knative 基本功能深入剖析:Knative Serving 之服务路由管理》


《Knative 实践:从源代码到服务的自动化部署》


2019-09-04 10:5411485
用户头像
阿里云容器平台 ACK,企业云原生转型最佳搭档

发布了 43 篇内容, 共 24.1 次阅读, 收获喜欢 81 次。

关注

评论 1 条评论

发布
用户头像
您好 级联那个场景 好像放错了流程图
2019-12-03 20:25
回复
没有更多了
发现更多内容

华为云Flexus云服务器X实例部署Trilium Notes知识库工具

YG科技

HarmonyOS next之flutter鸿蒙项目初体验

flfljh

HarmonyOS next之Flutter插件支持鸿蒙系

flfljh

docker 部署kafka及ui搭建

YG科技

LeetCode题解:2625. 扁平化嵌套数组,递归

Lee Chen

Elasticsearch VS Easysearch 性能测试

极限实验室

elasticsearch ES easysearch

云服务器Flexus X实例,镜像切换与服务器压力测试

YG科技

天润融通工单系统:一键催单功能提升客户满意度

天润融通

全面指南:使用华为云Flexus X部署私人图床

YG科技

DVWA靶场文件上传漏洞全级别通关及源码深度解析

代码忍者

华为云Flexus云服务器X实例之openEuler系统下部署WordPress网站

YG科技

华为云Flexus X实例docker部署ERPnext构建属于自己的企业资源规划系统

YG科技

深入解析华为云X实例保障云上业务安全的关键策略

YG科技

亚信科技研发智能化实践之路

阿里云云效

阿里云 云原生 通义灵码

Java面试突击手册,一周刷完这300道面试题,你也可以当架构师!

Summer

Java 程序员 面试 架构师 大厂

2025加密风云:行业变革与未来趋势全景透视

chainwiseweb3

加密货币 crypto dapp开发 区块链开发DAPP开发 链游开发公链开发

华为云Flexus云服务器X实例之openEuler系统下部署emlog轻量级博客平台

YG科技

EulerOS+Nginx+MySQL部署GLPI资产管理系统

YG科技

行业分享丨延锋国际基于数据分析和AI平台的仿真工具探索

Altair RapidMiner

人工智能 数据挖掘 数据分析 AI在仿真应用 ai与cae

VMware ESXi 8.0U3c macOS Unlocker & OEM BIOS 集成驱动版,新增 12 款 I219 网卡驱动

sysin

esxi

VMware ESXi 8.0U3c macOS Unlocker & OEM BIOS xFusion (超聚变) 定制版

sysin

Altair助力著名工业电子控制系统供应商Psicontrol提升PCB开发流程效率

Altair RapidMiner

EMC 电子设计 电磁仿真 PCB开发 FEKO

阿里拿38K出来的大佬良心分享,熬夜整理10 万字详细Java面试笔记!

Summer

Java 程序员 面试 架构师 大厂

2024年12月文章一览

codists

文章一览

HarmonyOS next之APP 服务卡片获取 APP 内数据

flfljh

社区信息化管理系统(源码+文档+部署+讲解)

深圳亥时科技

FORCE 大会开发者论坛演讲实录|吴一帆:边缘智能在 Agent 上的探索与实践

火山引擎边缘云

智能IoT边缘服务 AI 大底座 大模型、 边缘智能

利用华为云Flexus X实例解决家里公网80和443端口不开放问题

YG科技

亚信科技研发智能化实践之路

阿里巴巴云原生

阿里云 云原生

华为云Flexus X实例docker部署Rocket.Chat构建属于自己的团队通讯协作平台

YG科技

《计算机组成及汇编语言原理》阅读笔记:p177-p177

codists

计算机组成及汇编语言原理

Knative 基本功能深入剖析:Knative Eventing 之 Sequence 介绍_架构_阿里云容器平台_InfoQ精选文章