AI 事件驅動場景 Serverless 實踐

2022-08-03 18:18:14 字數 2063 閱讀 5574

事件驅動是指事件在持續事務管理過程中,進行決策的一種策略。可以通過調動可用資源執行相關任務,從而解決不斷出現的問題。通俗地說是當使用者觸發使用行為時對使用者行為的響應。在 serverless 場景下,事件驅動完美符合其設計初衷之一:按需付費。

圖:knative 模型

knative 主要包括兩大部分:一是用於工作負載的 serving,包括版本管理、灰度流量、自動彈性;二是 eventing(事件驅動框架)。

友商相關產品

knative 的 eventing 提供了乙個完整的事件模型,方便接入各個外部系統的事件。事件接入以後,通過 cloud event 標準在內部流轉,結合 broker-trigger 模型進行事件處理。

從上圖可以看到,eventing 中包含三部分內容:

事件規則的核心是 broker-trigger 模型,它包含以下特性:

knative 社群中提供了豐富的事件源接入,包括 kafka、github,也支援接入訊息雲產品的一些事件,比如 mns、rocketmq 等。

事件處理

典型案例

**提交自動構建映象。

訊息佇列 rocketmq 版是阿里雲基於 apache rocketmq 構建的低延遲、高併發、高可用、高可靠的分布式訊息中介軟體。

訊息佇列 rocketmq 版既可為分布式應用系統提供非同步解耦和削峰填谷的能力,同時也具備網際網路應用所需的海量訊息堆積、高吞吐、可靠重試等特性。

rocketmqsource 是 knative 平台的 rocketmq 事件源。其可以將 rocketmq 集群的訊息以 cloud event 的格式實時**到 knative 平台,是 apahe rocketmq 和 knative 之間的聯結器。

以具體場景為例,該案例是乙個直播系統,系統每天都有海量的直播訪問,訪問量根據直播熱度隨時變化,彈性有波動,同時存在不定時的增量。客戶的訴求,一是業務彈性波動,訊息併發性比較高;二是互動實時響應,要求低延遲。

為了滿足對訊息處理的彈性波動、高併發及低延遲的要求,客戶選擇阿里雲的 knative 服務進行資料的彈性處理。阿里雲 knative 完全契合了使用者當前的訴求,並且在接入 k8s 標準之上,提供了基於事件和訊息的彈性排程。

當應用例項數隨著業務的波峰波谷進行擴容和縮容時,真正做到了按需使用、實時彈性的能力。整個過程完全自動化,減少業務開發人員在基礎設施上的負擔。在這個案例中,knative 主要提供了三個能力:極致彈性、事件處理、開箱即用。

下面進行示例演示,演示內容主要有:

作者簡介:

李鵬,花名:元毅,阿里雲容器平台高階開發工程師,2016 年加入阿里, 深度參與了阿里巴巴全面容器化、連續多年支援雙十一容器化鏈路。專注於容器、kubernetes、service mesh 和 serverless 等雲原生領域,致力於構建新一代 serverless 平台。當前負責阿里雲容器服務 knative 相關工作。

驅動python python實現事件驅動

eventmanager事件管理類實現,大概就百來行 左右。encoding utf 8 系統模組 from queue import queue,empty from threading import class eventmanager def init self 初始化事件管理器 事件物件列表...

事件驅動與流程驅動

1 流程驅動 類似 一般就是主動輪詢 在幹活中還要分心 主動去找活幹 這樣有空餘的時間也完全浪費掉了 2 事件驅動 類似 比如公司有乙個oa系統 你幹完活的時候只需要看下oa系統有沒分配給你活 沒有可以幹自己的事 不用擔心還有其他事沒幹完 3者對比 採用警覺式者主動去輪詢 polling 行為取決於...

事件驅動之非同步事件

public void head private void raiseevent headedevent headedevent 所以我們只需在 裡raiseevent就可以了。其實很簡單,因為我們要實現的是同步的事件,我們只需要找到所有處理這個事件的實現類,然後呼叫所有就可以了。public in...