限时领|《AI 百问百答》专栏课+实体书(包邮)! 了解详情
写点什么

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:5411494
用户头像
阿里云容器平台 ACK,企业云原生转型最佳搭档

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

关注

评论 1 条评论

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

探索 Coinbase 二层链 Base 的潜力与风险

Footprint Analytics

以太坊 Base Coinbase

小红书基于零信任 SASE 办公安全解决方案,斩获 “IDC 中国 20 大杰出安全项目”

小红书技术REDtech

大数据 网络安全 安全

数字化转型对中小企业来说值得吗?

天津汇柏科技有限公司

数字化转型

TFTP服务器 Transfer免激活最新版

胖墩儿不胖y

Mac 软件 ftp传输

年底换机的实力派选择:华为畅享70性能出色,体验超便捷

极客天地

微店商品详情数据接口(micro.item_get)|微店API接口

tbapi

微店商品详情数据接口 微店商品API接口 微店API接口

引迈信息-JNPF平台怎么样?值得入手吗?

互联网工科生

低代码 开发平台 JNPF

语音数据集在人工智能中的应用与挑战

数据堂

语音数据集在智能语音助手中的应用与挑战

数据堂

为什么说代码注释是程序员必备的技能?

小魏写代码

关于C#反射概念,附带案例!

不在线第一只蜗牛

C# 后端 项目开发

网心科技出席2023(第二十一届)中国企业领袖年会,共话长期主义

网心科技

网心科技

如何通过京东工业商品API接口获取商品详情

Noah

JDBC ResulSet资源释放和Statement并发调用源码分析

FunTester

语音数据集:AI语音技术的灵魂

数据堂

速卖通商品API接口的使用指南与示例

Noah

测试用例设计方法六脉神剑——第四剑:石破天惊,功能图法攻阵| 京东物流技术团队

京东科技开发者

有意思!40小时工作制来了,996再见

伤感汤姆布利柏

软件测试/人工智能丨为什么人工智能=大数据+机器学习

测试人

人工智能 软件测试

大数据时代的数据治理!

用友BIP

数据治理

百度搜索展现服务重构:进步与优化

百度Geek说

重构 企业号12月PK榜 百度搜索展现

特权账号管理误区

尚思卓越

网络安全 运维安全 特权账号管理

Amazon CodeWhisperer:AI 编程助手

亚马逊云科技 (Amazon Web Services)

人工智能 Amazon Lambda 云上探索实验室 Amazon CodeWhisperer Amazon Cloud9

Knative 基本功能深入剖析:Knative Eventing 之 Sequence 介绍_架构_元毅_InfoQ精选文章