【云原生系列】第五讲：Knative Eventing 下

news2024/10/7 20:27:10

目录

序言

1.Parallel介绍

1.1 Parallel Spec 

​编辑 

2.Sequence

2.1.Sequence Spec

2.2适用场景

2.3 Broker/Trigger

2.4 代码示例

3.投票

序言

三言两语，不如细心探索。

今天整理了一下Eventing 相关知识点

  • Parallel
  • Sequence

希望此文，能帮助读者对Knative Eventing 的这两个知识点有一个初步的了解

文章标记颜色说明：

  • 黄色：重要标题
  • 红色：用来标记结论
  • 绿色：用来标记一级论点
  • 蓝色：用来标记二级论点

1.Parallel介绍

学习Parallel 的时候，看了很多资料，其中觉得比较全面的是：

Flows - Parallel - 《Knative v1.8 Documentation》

Parallel CRD provides a way to easily define a list of branches,

each receiving the same CloudEvent sent to the Parallel ingress channel.

Typically, each branch consists of a filter function guarding the execution of the branch.

Parallel creates Channels and Subscriptions under the hood.

总结下来，就是支持根据不同的过滤条件对事件进行选择处理

1.1 Parallel Spec 

 Parallel 资源定义，典型的 Parallel Spec描述如下：

apiVersion: messaging.knative.dev/v1alpha1
kind: Parallel
metadata:
  name: me-odd-even-parallel
spec:
  channelTemplate:
    apiVersion: messaging.knative.dev/v1alpha1
    kind: InMemoryChannel
  cases:
    - filter:
        uri: "http://me-even-odd-switcher.default.svc.cluster.local/0"
      subscriber:
        ref:
          apiVersion: serving.knative.dev/v1alpha1
          kind: Service
          name: me-even-transformer
    - filter:
        uri: "http://me-even-odd-switcher.default.svc.cluster.local/1"
      subscriber:
        ref:
          apiVersion: serving.knative.dev/v1alpha1
          kind: Service
          name: me-odd-transformer
  reply:
    apiVersion: serving.knative.dev/v1alpha1
    kind: Service
    name: me-event-display

主要包括3个部分：

  • channelTemplate：定义了当前 Parallel 中使用的Channel类型

  • cases ：定义了一系列 filter 和 subscriber。对于每个条件分支：

    • filter：首先判断 filter， 当返回事件时，调用 subscriber。filter和subscriber要求都是可访问的。
    • subscriber： 执行返回的事件会发生到 reply。如果 reply 为空，则发送到 spec.reply
  • reply ：定义了全局响应的目标函数。为可选配置

其架构流程如下图

2.Sequence

主要学习了该文章，感谢作者大大：

Knative Eventing 之 Sequence 介绍

Sequence 是Knative Eventing中提供了一个资源模型，主要是为了支持对一个事件进行分步骤多次处理的场景。简单说，用于事件Pipeline处理。概括下来，有以下2点：

  • 一种资源模型
  • 事件Pipeline处理

2.1.Sequence Spec

Sequence Spec  的demo示例

apiVersion: messaging.knative.dev/v1alpha1
kind: Sequence
metadata:
  name: sequencetest
spec:
  channelTemplate:
    apiVersion: messaging.knative.dev/v1alpha1
    kind: InMemoryChannel
  steps:
    - ref:
        apiVersion: serving.knative.dev/v1alpha1
        kind: Service
        name: sequencetest1
    - ref:
        apiVersion: serving.knative.dev/v1alpha1
        kind: Service
        name: sequencetest2
    - ref:
        apiVersion: serving.knative.dev/v1alpha1
        kind: Service
        name: sequencetest3
  reply:
    kind: Broker
    apiVersion: eventing.knative.dev/v1alpha1
    name: sequencetest4

从定义中可以看出：

Sequence Spec包括3个部分：

  1. channelTemplate：指定了具体使用的Channel
  2. steps： 定义了按照顺序执行的服务，而且每个服务会对应创建Subscription。这里定义了三个步骤。每个步骤执行不同的服务
  3. reply：定义了最后一个step返回结果的响应目标，这一步骤是可选

2.2适用场景

Sequence 在 Knative Eventing 中提供的如下 4 种使用场景：

  1.  Broker/Trigger

  2. 级联 Sequence

  3. 面向事件处理

  4. 直接访问 Service

2.3 Broker/Trigger

该类型是最复杂的一个场景：

事件源 cronjobsource 向 Broker 发送事件，通过 Trigger 将这些事件发送到由 多个 Service 调用的 Sequence 中。

Sequence 处理完之后将结果事件发送给 Broker，并最终由另一个 Trigger 发送给 event-display Service 显示事件结果。

如下图所示：

2.4 代码示例

主要分为以下几步骤，分别创建： 

  1. knative Service
  2. Sequence
  3. Broker
  4. 创建事件源
  5. Trigger  指向 Sequence
  6. 结果订阅 Trigger

1.创建knative Service

创建 3 个 Knative Service，用于 Sequence 中服务处理。

--- 第一个service -one
apiVersion: serving.knative.dev/v1alpha1
kind: Service
metadata:
  name: one
spec:
  template:
    spec:
      containers:
      - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
        env:
        - name: STEP
          value: "1"

--- 第二个service - two
apiVersion: serving.knative.dev/v1alpha1
kind: Service
metadata:
  name: two
spec:
  template:
    spec:
      containers:
      - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
        env:
        - name: STEP
          value: "2"
--- 第三个
apiVersion: serving.knative.dev/v1alpha1
kind: Service
metadata:
  name: three
spec:
  template:
    spec:
      containers:
      - image: registry.cn-hangzhou.aliyuncs.com/knative-sample/probable-summer:2656f39a7fcb6afd9fc79e7a4e215d14d651dc674f38020d1d18c6f04b220700
        env:
        - name: STEP
          value: "3"

2.创建 Sequence

创建 Sequence，依次顺序执行 one->two->three 这 3 个服务。

将最终处理的结果发送到 broker-test 中。

apiVersion: messaging.knative.dev/v1alpha1
kind: Sequence
metadata:
  name: sequence
spec:
  channelTemplate:
    apiVersion: messaging.knative.dev/v1alpha1
    kind: InMemoryChannel
  steps:
    - ref:
        apiVersion: serving.knative.dev/v1alpha1
        kind: Service
        name: one
    - ref:
        apiVersion: serving.knative.dev/v1alpha1
        kind: Service
        name: two
    - ref:
        apiVersion: serving.knative.dev/v1alpha1
        kind: Service
        name: three
  reply:
    kind: Broker
    apiVersion: eventing.knative.dev/v1alpha1
    name: broker-test

3.创建broker

创建默认的broker

kubectl label namespace default knative-eventing-injection=enabled

4.创建事件源

创建事件源指向 Broker

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

apiVersion: sources.eventing.knative.dev/v1alpha1
kind: CronJobSource
metadata:
  name: cronjob-source
spec:
  schedule: "*/1 * * * *"
  data: '{"message": "Hello Knative Sequence!"}'
  sink:
    apiVersion: eventing.knative.dev/v1alpha1
    kind: Broker
    name: broker-test

5.Trigger  指向 Sequence 

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

apiVersion: eventing.knative.dev/v1alpha1
kind: Trigger
metadata:
  name: sequence-trigger
spec:
  filter:
    sourceAndType:
      type: dev.knative.cronjob.event
  subscriber:
    ref:
      apiVersion: messaging.knative.dev/v1alpha1
      kind: Sequence
      name: sequence

6.结果订阅 Trigger

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

apiVersion: eventing.knative.dev/v1alpha1
kind: Trigger
metadata:
  name: display-trigger
spec:
  filter:
    sourceAndType:
      type: samples.http.mod3
  subscriber:
    ref:
      apiVersion: serving.knative.dev/v1alpha1
      kind: Service
      name: event-display
---
apiVersion: serving.knative.dev/v1alpha1
kind: Service
metadata:
  name: event-display
spec:
  template:
    spec:
      containers:
        - image: registry.cn-hangzhou.aliyuncs.com/knative-release/event_display:bf45b3eb1e7fc4cb63d6a5a6416cf696295484a7662e0cf9ccdf5c080542c21d
---

参考：

Flows - Parallel - 《Knative v1.8 Documentation》

Knative Sequence 介绍

3.投票

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/51863.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

C#正则表达式总结

C#正则表达式总结

推荐一个专门用于编写正则表达式的网站： regex101: build, test, and debug regex 参考文档： https://zh.wikipedia.org/wiki/%E6%AD%A3%E5%88%99%E8%A1%A8%E8%BE%BE%E5%BC%8F 特殊字符的意义： ^ : 表示字符串的开头 例子： …
阅读更多...
局域网的网络硬件主要包括有什么

局域网的网络硬件主要包括有什么

一、网络服务器 是计算机局域网的核心部件。 网络操作系统是在网络服务器上运行的，网络服务器的效率直接影响整个网络的效率。 因此，一般要用高档计算机或专用服务器计算机作为网络服务器。 二、网络工作站 网络工作站是通过网络接口卡连接到网络上的…
阅读更多...
银行软件测试：基于互联网金融平台的测试框架设计与分析

银行软件测试：基于互联网金融平台的测试框架设计与分析

目前互联网金融火的一塌糊涂，基于互联网金融平台的自动化测试的项目也是如火如荼的进行。笔者手头上负责一个p2p项目的测试框架开发，因此如何设计一套有效的测试框架也成为工作所需和互相交流测试经验的必须。进入》软件测试社群学习交流 这个网站的后台…
阅读更多...
科研绘图配色方案

科研绘图配色方案

科研绘图配色方案 在撰写论文的时候，美观，大气，上档次的图表能够很好地给自己的论文加分。但是在绘制图表的时候往往会面临色彩搭配的问题，选择合适的色彩搭配能够有效地展示自己的方法，但是色彩搭配选择不当的话往往…
阅读更多...
Go学习之路：并发（DAY 3）

Go学习之路：并发（DAY 3）

文章目录前引并发1、Go协程/简单创建2.1、信道/简单创建信道2.2、信道/限制了大小的信道2.3、信道/range close信道3.1、Select语句前引 听了会歌 一看了下今天已经下午2：50了 我们学校也好像开始放学生们回家了 那今天最后就愉快愉快的把我们的 A Tour Of Go 最后…
阅读更多...
申报高新技术企业需要哪些条件？

申报高新技术企业需要哪些条件？

高新技术企业是在国家重点支持的高新技术领域中持续进行科研开发和技术成果转化，形成企业核心自主知识产权，并以此为基础开展生产经营活动的企业。成为高新技术企业以后会减免40%的所得税。 申报高新技术企业需要哪些条件？ 第一点&#xff…
阅读更多...
回收站不见了怎么恢复？一招把回收站的图标找回来！

回收站不见了怎么恢复？一招把回收站的图标找回来！

有时我们会有这样的烦恼，明明回收站里面的东西还没被删除或者是还在回收站里面，但是回收站的图标就是看不到了。其实，这正是我们所说的电脑回收站不显示图标导致。因为我们关闭回收站位置以后，电脑系统都会自动把回收站置为“已删…
阅读更多...
TPM零知识学习四 —— tpm2-tss源码安装

TPM零知识学习四 —— tpm2-tss源码安装

tpm2-tss包的的安装方法参考： tpm2-tss/INSTALL.md at master tpm2-software/tpm2-tss GitHub 1. 源码下载 $ git clone https://github.com/tpm2-software/tpm2-tss.git 下载完成后，源码内容如下所示： $ ls afl-fuzzing CHANGELOG.m…
阅读更多...
基于ssm的小区物业管理系统

基于ssm的小区物业管理系统

项目描述 临近学期结束，还是毕业设计，你还在做java程序网络编程，期末作业，老师的作业要求觉得大了吗?不知道毕业设计该怎么办?网页功能的数量是否太多?没有合适的类型或系统?等等。这里根据疫情当下，你想解决的问…
阅读更多...
mac下安装nodejs跟vscode

mac下安装nodejs跟vscode

1.打开官网 Node.js 2.点击下载 3.下载完成，根据提示下一步安装，安装完成后，在vscode中新建一个js文件，执行node test.js
阅读更多...
[附源码]计算机毕业设计ssm新能源电动汽车充电桩服务APPSpringboot程序

[附源码]计算机毕业设计ssm新能源电动汽车充电桩服务APPSpringboot程序

项目运行 环境配置： Jdk1.8 Tomcat7.0 Mysql HBuilderX（Webstorm也行） Eclispe（IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持）。 项目技术： SSM mybatis Maven Vue 等等组成，B/S模式 M…
阅读更多...
opencv c++ 图像噪声及去噪

opencv c++ 图像噪声及去噪

1、噪声类型及生成 1.1、类型 高斯噪声、椒盐噪声、泊松噪声、乘性噪声，等。 具体解释参考：(31条消息) 图像噪声简介_yeler082的博客-CSDN博客_图像噪声 高斯噪声 泊松噪声 乘性噪声 …
阅读更多...
AWS SAP-C02 考试指南

AWS SAP-C02 考试指南

Hello大家好，欢迎来到AWS解决方案架构师professional中文视频培训课程，我是讲师沉默恶魔。 本课时的内容是SAP-C02考试指南，我将介绍有关SAP-C02考试的详细信息。 SAP-C02是解决方案架构师专业级认证的最新版本的考试，目前也只能…
阅读更多...
空域图像增强-图像滤波处理

空域图像增强-图像滤波处理

3.图像滤波处理。自选一张图片，完成以下图像处理：①给图像分别添加随机噪声和椒盐噪声；②采用不同的平滑滤波模板进行滤波对比（不同模板、不同尺寸）；③采用中值滤波对图像进行滤波对比；④对添加…
阅读更多...
GEE开发之Modis_NPP数据分析和获取

GEE开发之Modis_NPP数据分析和获取

GEE开发之Modis_NPP数据分析和获取1.NPP2.MOD系列和MYD系列区别3.MOD17A3H_v006(500m/1年)4.MOD17A3HGF_v006(500m/1年)5.MOD17A3HGF_v061(500m/1年)6.MYD17A3H_v006(500m/1年)6.1 MYD17A3H下的指数6.2 遥感影像查看7.MYD17A3HGF_v061(500m/1年)8.MYD17A3HGF_v006(500m/1年)9.N…
阅读更多...
行业应用之无限可能，就在亚马逊云科技re:Invent

行业应用之无限可能，就在亚马逊云科技re:Invent

在2022亚马逊云科技re:Invent全球大会Adam Selipsky“如何借助云的力量，在未知领域抓住机遇并茁壮成长”的主题演讲中，除了阐述主要的产品升级以外，亚马逊云科技还致力于打造面向特定行业或者特定应用场景的解决方案，以帮助客户快…
阅读更多...
【Mongoose应用和文件上传】一.Express框架访问MongDB数据库；二.node实现文件上传

【Mongoose应用和文件上传】一.Express框架访问MongDB数据库；二.node实现文件上传

目录 一.Express框架访问MongDB数据库 1.目的： （1）mongoose模块的使用 （2）学会代码的封装：dao层、service层、接口层 （3）MVC设计思想：M（Model&#xff0…
阅读更多...
5.RabbitMQ高级特性

5.RabbitMQ高级特性

5.RabbitMQ高级特性 为什么不是RabbitMQ的事务？ 这是从官网直接翻译过来的：网络可能以不太明显的方式出现故障，而且检测某些故障需要时间。因此，向套接字编写协议帧或一组帧(例如发布的消息)的客户端不能假定消息已经到达服务器…
阅读更多...
【库存控制】基于蜜蜂算法优化库存控制附matlab代码

【库存控制】基于蜜蜂算法优化库存控制附matlab代码

✅作者简介：热爱科研的Matlab仿真开发者，修心和技术同步精进，matlab项目合作可私信。 🍎个人主页：Matlab科研工作室 🍊个人信条：格物致知。 更多Matlab仿真内容点击👇 智能优化算法 …
阅读更多...
如何将dwg文件转成kml文件

如何将dwg文件转成kml文件

第一步： 在CAD中将DWG另存为 DXF，如下： 注意：（中文乱码）为了打开的中文不出现乱码，保存DXF文件请选择如下的选项 第二步： 下载安装Bigemap GIS Office download.bigemap.com/bmset…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023