08-Event Sources和Sink架构

2023-12-18 21:20
文章标签 架构 08 sink event sources

本文主要是介绍08-Event Sources和Sink架构，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1 PingSource -> Kubernetes Service Sink

  • 架构模型

    在这里插入图片描述

  • 示例1

    • 部署一个kubernetes类型的sink，这里面还是以event-display为例，下面是资源清单

      ---
apiVersion: apps/v1
kind: Deployment
metadata:name: event-display
spec:replicas: 1selector:matchLabels: &labelsapp: event-displaytemplate:metadata:labels: *labelsspec:containers:- name: event-displayimage: ikubernetes/event_display
---
kind: Service
apiVersion: v1
metadata:name: event-display
spec:selector:app: event-displayports:- protocol: TCPport: 80targetPort: 8080

    • 定义pingsource资源，指定sink为event-display

      apiVersion: sources.knative.dev/v1
kind: PingSource
metadata:name: ping-00001
spec:schedule: "* * * * *"contentType: "application/json"data: '{"message": "Hello Eventing!"}'sink:ref:apiVersion: v1kind: Servicename: event-display

      后面knative-eventing的namespace会出现pingsource的POD

      在这里插入图片描述

    • 获取event-display当中的日志信息，验证是否进行了事件发送

      kubectl logs -f event-display-6496b6c66d-7drk5

      在这里插入图片描述

2 PingSource → Knative Service Sink

  • 架构

    外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

  • 示例2

    • 部署一个kservice类型的sink，这里面还是以event-display为例，下面是资源清单

      ---
apiVersion: serving.knative.dev/v1
kind: Service
metadata:name: event-display
spec:template:metadata:annotations:autoscaling.knative.dev/min-scale: "1"spec:containers:- image: ikubernetes/event_displayports:- containerPort: 8080

    • 定义pingsource资源，指定sink为event-display

      ---
apiVersion: sources.knative.dev/v1
kind: PingSource
metadata:name: pingsource-00001
spec:schedule: "* * * * *"contentType: "application/json"data: '{"message": "Hello Eventing!"}'sink:ref:apiVersion: serving.knative.dev/v1kind: Servicename: event-display

    • 获取event-display当中的日志信息，验证是否进行了事件发送

      kubectl logs -f event-display-00001-deployment-7f488cb57b-grsc6

      在这里插入图片描述

3 ContainerSource → Knative Service Sink

  • 旨在收集一些容器的event是，比如容器的一些元数据，下面是架构：

    在这里插入图片描述

  • 示例2

    • 部署一个kservice类型的sink，这里面还是以event-display为例，下面是资源清单

      ---
apiVersion: serving.knative.dev/v1
kind: Service
metadata:name: event-display
spec:template:metadata:annotations:autoscaling.knative.dev/min-scale: "1"spec:containers:- image: ikubernetes/event_displayports:- containerPort: 8080

    • 定义containergsource资源，指定sink为event-display

      apiVersion: sources.knative.dev/v1
kind: ContainerSource
metadata:name: containersource-heartbeat
spec:template:spec:containers:- image: ikubernetes/containersource-heartbeats:latestname: heartbeatsenv:- name: POD_NAMEvalueFrom:fieldRef:fieldPath: metadata.name- name: POD_NAMESPACEvalueFrom:fieldRef:fieldPath: metadata.namespacesink:ref:apiVersion: serving.knative.dev/v1kind: Servicename: event-display

      在event-display的名称空间创建了一个containersource的pod

      在这里插入图片描述

    • 获取event-display当中的日志信息，验证是否进行了事件发送

      kubectl logs -f event-display-00001-deployment-645944b779-2b4vt

      在这里插入图片描述

4 ApiServerSource → Knative Service Sink

  • apiserversource主要记录了aoiserver上的event，比如create/delete/update/get，架构如下：

    在这里插入图片描述

  • 示例4：

    • 部署一个kservice类型的sink，这里面还是以event-display为例，下面是资源清单

      ---
apiVersion: serving.knative.dev/v1
kind: Service
metadata:name: event-display
spec:template:metadata:annotations:autoscaling.knative.dev/min-scale: "1"spec:containers:- image: ikubernetes/event_displayports:- containerPort: 8080

    • 定义ServiceAccount：定义向指定目标资源的get,watch,list的相关权限

      apiVersion: v1
kind: ServiceAccount
metadata:name: pod-watcher
---
apiVersion: rbac.authorization.k8s.io/v1
kind: Role
metadata:name: pod-reader
rules:
- apiGroups:- ""resources:- podsverbs:- get- list- watch
---
apiVersion: rbac.authorization.k8s.io/v1
kind: RoleBinding
metadata:name: pod-reader
roleRef:apiGroup: rbac.authorization.k8s.iokind: Rolename: pod-reader
subjects:
- kind: ServiceAccountname: pod-watcher

    • 定义apiserversource资源，结合serviceaccount，对指定权限的pod进行收集event

      apiVersion: sources.knative.dev/v1
kind: ApiServerSource
metadata:name: pods-event
spec:serviceAccountName: pod-watchermode: Referenceresources:- apiVersion: v1kind: Podsink:ref:apiVersion: serving.knative.dev/v1kind: Servicename: event-display

      会发现创建一个apiserversource的pod

      在这里插入图片描述

    • 获取event-display当中的日志信息，验证是否进行了事件发送

      kubectl logs -f event-display-00001-deployment-9469968cd-vb4l2

      在这里插入图片描述

5 GitLab Source

  • 关于GitLabSource
    • 将GitLab仓库上的事件转为CloudEvents
    • GitLabSource为指定的事件类型创建一个Webhook，监听传入的事件，并将其传给消费者
  • GitLabSource支持的事件类型包括如下这些：
    • 推送事件：push_events
      • 对应的CloudEvents的类型为“dev.knative.sources.gitlab.push”，以下类同
    • tag推送事件：tag_push_events
    • 议题事件：issues_events
    • 合并请求事件：merge_requests_events
    • 私密议题事件：confidential_issues_events
    • 私密评论：confidential_note_events
    • 部署事件：deployment_events
    • 作业事件：job_events
    • 评论：note_events
    • 流水线事件：pipeline_events
    • Wiki页面事件：wiki_page_events
5.1 GitLab Source 实践

  • 示例环境说明

    • 一个部署可用的GitLab服务
    • GitLab服务上隶于某个用户（例如root）的代码仓库（例如myproject）
    • 负责接收CloudEvents的kservice/event-display

    在这里插入图片描述

  • 具体步骤

    • 部署Gitlab
    • GitLab上的操作
      • 为GitLab用户设置Personal Access Token
      • 准备示例仓库myproject
    • 在Knative上部署GitLabSource
    • 在Knative上部署KService/event-display
    • 创建Secret资源，包含两个数据项
      • GitLab上的Personal Access Token
      • GitLab调用GitLabSource与Webhook Secret
    • 创建GitLabSource资源
      • 从GitLab仓库加载事件
      • 将事件转为CloudEvents，并发往Sink

  • 具体操作

    • 部署GitLab
    • Gitlab上操作
      • 通用→可见性：设定“自定义HTTP(S)协议Git克隆URL”

这篇关于08-Event Sources和Sink架构的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/509789。

相关文章

Knife4j+Axios+Redis前后端分离架构下的 API 管理与会话方案(最新推荐)

Knife4j+Axios+Redis前后端分离架构下的 API 管理与会话方案(最新推荐)

《Knife4j+Axios+Redis前后端分离架构下的API管理与会话方案(最新推荐)》本文主要介绍了Swagger与Knife4j的配置要点、前后端对接方法以及分布式Session实现原理,... 目录一、Swagger 与 Knife4j 的深度理解及配置要点Knife4j 配置关键要点1.Spri
阅读更多...
mysql中的服务器架构详解

mysql中的服务器架构详解

《mysql中的服务器架构详解》：本文主要介绍mysql中的服务器架构,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、背景2、mysql服务器架构解释3、总结1、背景简单理解一下mysqphpl的服务器架构。2、mysjsql服务器架构解释mysql的架
阅读更多...
k8s上运行的mysql、mariadb数据库的备份记录(支持x86和arm两种架构)

k8s上运行的mysql、mariadb数据库的备份记录(支持x86和arm两种架构)

《k8s上运行的mysql、mariadb数据库的备份记录(支持x86和arm两种架构)》本文记录在K8s上运行的MySQL/MariaDB备份方案,通过工具容器执行mysqldump,结合定时任务实... 目录前言一、获取需要备份的数据库的信息二、备份步骤1.准备工作（X86）1.准备工作（arm）2.手
阅读更多...
Maven 插件配置分层架构深度解析

Maven 插件配置分层架构深度解析

《Maven插件配置分层架构深度解析》：本文主要介绍Maven插件配置分层架构深度解析,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录Maven 插件配置分层架构深度解析引言：当构建逻辑遇上复杂配置第一章 Maven插件配置的三重境界1.1 插件配置的拓扑
阅读更多...
Java异常架构Exception(异常)详解

Java异常架构Exception(异常)详解

《Java异常架构Exception(异常)详解》：本文主要介绍Java异常架构Exception(异常),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1. Exception 类的概述Exception的分类2. 受检异常（Checked Exception）
阅读更多...
MySQL 缓存机制与架构解析(最新推荐)

MySQL 缓存机制与架构解析(最新推荐)

《MySQL缓存机制与架构解析(最新推荐)》本文详细介绍了MySQL的缓存机制和整体架构,包括一级缓存（InnoDBBufferPool）和二级缓存（QueryCache）,文章还探讨了SQL... 目录一、mysql缓存机制概述二、MySQL整体架构三、SQL查询执行全流程四、MySQL 8.0为何移除查
阅读更多...
微服务架构之使用RabbitMQ进行异步处理方式

微服务架构之使用RabbitMQ进行异步处理方式

《微服务架构之使用RabbitMQ进行异步处理方式》本文介绍了RabbitMQ的基本概念、异步调用处理逻辑、RabbitMQ的基本使用方法以及在SpringBoot项目中使用RabbitMQ解决高并发... 目录一.什么是RabbitMQ？二.异步调用处理逻辑：三.RabbitMQ的基本使用1.安装2.架构
阅读更多...
mybatis的整体架构

mybatis的整体架构

mybatis的整体架构分为三层： 1.基础支持层 该层包括：数据源模块、事务管理模块、缓存模块、Binding模块、反射模块、类型转换模块、日志模块、资源加载模块、解析器模块 2.核心处理层 该层包括：配置解析、参数映射、SQL解析、SQL执行、结果集映射、插件 3.接口层 该层包括：SqlSession 基础支持层 该层保护mybatis的基础模块，它们为核心处理层提供了良好的支撑。
阅读更多...
百度/小米/滴滴/京东，中台架构比较

百度/小米/滴滴/京东，中台架构比较

小米中台建设实践 01 小米的三大中台建设：业务+数据+技术 业务中台--从业务说起 在中台建设中，需要规范化的服务接口、一致整合化的数据、容器化的技术组件以及弹性的基础设施。并结合业务情况，判定是否真的需要中台。 小米参考了业界优秀的案例包括移动中台、数据中台、业务中台、技术中台等，再结合其业务发展历程及业务现状，整理了中台架构的核心方法论，一是企业如何共享服务，二是如何为业务提供便利。
阅读更多...
【前端学习】AntV G6-08 深入图形与图形分组、自定义节点、节点动画（下）

【前端学习】AntV G6-08 深入图形与图形分组、自定义节点、节点动画（下）

【课程链接】 AntV G6：深入图形与图形分组、自定义节点、节点动画（下）_哔哩哔哩_bilibili 本章十吾老师讲解了一个复杂的自定义节点中，应该怎样去计算和绘制图形，如何给一个图形制作不间断的动画，以及在鼠标事件之后产生动画。（有点难，需要好好理解） <!DOCTYPE html><html><head><meta charset="UTF-8"><title>06
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2