你所在的位置: 首页 > 正文

Knative Eventing 之 Sequence 介绍

2019-08-24 点击:1480

处理数据时,通常涉及需要多次处理的数据。目前,我们通常通过Pipeline处理它。那么在Knative Eventing中它还可以支持多次逐步处理事件吗?这是真的。从版本0.7开始,在Knative Eventing中为事件管道处理提供了序列资源模型。

首先让我们看一下Sequence Spec定义:

序列规范由3部分组成:

步骤:定义按步骤顺序执行的服务,每个服务都将创建订阅。

channelTemplate:指定要使用的特定通道

回复:(可选)定义最后一步返回结果的响应目标

我们将创建以下逻辑配置。创建一个cronjobsource,向代理提供事件,然后创建一个过滤器,将事件连接到3个步骤的序列。然后,我们将最后一步返回结果事件发送给Broker并创建另一个Trigger,然后显示事件结果。

对于此示例,这里是Broker程序,InMemoryChannel和Knative Service(用于显示事件结果)。该示例使用默认命名空间。

如果要使用其他类型的Channel,则需要对其进行修改以创建相应的Channel资源。

2509688-f3ec7b8d8825f613.png

首先在Sequence

中为服务处理创建3 Knative Service

执行create命令:

创建一个序列,按顺序执行三个服务[first-> gt; second-> third]。最终处理结果将发送到代理测试。

执行以下命令:

消息。

执行命令如下:

使用订阅事件类型dev.knative.cronjob.event创建一个Trigger,以便对Sequence进行消费处理。

执行以下命令:

创建结果订阅触发器,订阅事件类型,并显示序列执行的结果

使用Sequence资源模型,可以很容易地在Knative Eventing中实现事件处理的Pipeline。特别适用于需要多步处理的服务。

作者:袁毅

阅读原文

本文是云栖社区的原创内容,未经许可,不得转载。

96

阿里云云栖社区

96daa9ff-5e2d-4ab8-9769-04a0eb468046

1.5

2019.08.05 13: 37

字数635

处理数据时,通常涉及需要多次处理的数据。目前,我们通常通过Pipeline处理它。那么在Knative Eventing中它还可以支持多次逐步处理事件吗?这是真的。从版本0.7开始,在Knative Eventing中为事件管道处理提供了序列资源模型。

首先让我们看一下Sequence Spec定义:

序列规范由3部分组成:

步骤:定义按步骤顺序执行的服务,每个服务都将创建订阅。

channelTemplate:指定要使用的特定通道

回复:(可选)定义最后一步返回结果的响应目标

我们将创建以下逻辑配置。创建一个cronjobsource,向代理提供事件,然后创建一个过滤器,将事件连接到3个步骤的序列。然后,我们将最后一步返回结果事件发送给Broker并创建另一个Trigger,然后显示事件结果。

对于此示例,这里是Broker程序,InMemoryChannel和Knative Service(用于显示事件结果)。该示例使用默认命名空间。

如果要使用其他类型的Channel,则需要对其进行修改以创建相应的Channel资源。

2509688-f3ec7b8d8825f613.png

首先在Sequence

中为服务处理创建3 Knative Service

执行create命令:

创建一个序列,按顺序执行三个服务[first-> gt; second-> third]。最终处理结果将发送到代理测试。

执行以下命令:

消息。

执行命令如下:

使用订阅事件类型dev.knative.cronjob.event创建一个Trigger,以便对Sequence进行消费处理。

执行以下命令:

创建结果订阅触发器,订阅事件类型,并显示序列执行的结果

使用Sequence资源模型,可以很容易地在Knative Eventing中实现事件处理的Pipeline。特别适用于需要多步处理的服务。

作者:袁毅

阅读原文

本文是云栖社区的原创内容,未经许可,不得转载。

处理数据时,通常涉及需要多次处理的数据。目前,我们通常通过Pipeline处理它。那么在Knative Eventing中它还可以支持多次逐步处理事件吗?这是真的。从版本0.7开始,在Knative Eventing中为事件管道处理提供了序列资源模型。

首先让我们看一下Sequence Spec定义:

序列规范由3部分组成:

步骤:定义按步骤顺序执行的服务,每个服务都将创建订阅。

channelTemplate:指定要使用的特定通道

回复:(可选)定义最后一步返回结果的响应目标

我们将创建以下逻辑配置。创建一个cronjobsource,向代理提供事件,然后创建一个过滤器,将事件连接到3个步骤的序列。然后,我们将最后一步返回结果事件发送给Broker并创建另一个Trigger,然后显示事件结果。

对于此示例,这里是Broker程序,InMemoryChannel和Knative Service(用于显示事件结果)。该示例使用默认命名空间。

如果要使用其他类型的Channel,则需要对其进行修改以创建相应的Channel资源。

2509688-f3ec7b8d8825f613.png

首先在Sequence

中为服务处理创建3 Knative Service

执行create命令:

创建一个序列,按顺序执行三个服务[first-> gt; second-> third]。最终处理结果将发送到代理测试。

执行以下命令:

消息。

执行命令如下:

使用订阅事件类型dev.knative.cronjob.event创建一个Trigger,以便对Sequence进行消费处理。

执行以下命令:

创建结果订阅触发器,订阅事件类型,并显示序列执行的结果

使用Sequence资源模型,可以很容易地在Knative Eventing中实现事件处理的Pipeline。特别适用于需要多步处理的服务。

作者:袁毅

阅读原文

本文是云栖社区的原创内容,未经许可,不得转载。

深圳新闻网 版权所有© www.sucdutedu.org 技术支持:深圳新闻网 | 网站地图