基于 ASK + EB 构建容器事件驱动服务-阿里云开发者社区

基于 ASK + EB 构建容器事件驱动服务

2022-01-06 571

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

Serverless 应用引擎 SAE，800核*时 1600GiB*时

容器镜像服务 ACR，镜像仓库100个不限时长

EMR Serverless StarRocks，5000CU*H 48000GB*H

简介： 本篇文章以“在线文件解压场景”为例为大家展示经典 EDA 事件驱动与容器如何搭配使用。

作者：冬岛、肯梦

导读

EDA 事件驱动架构( Event-Driven Architecture ) 是一种系统架构模型，它的核心能力在于能够发现系统“事件”或重要的业务时刻（例如交易节点、站点访问等）并实时或接近实时地对相应的事件采取必要行动。那么 EDA + 容器能擦出怎样的火花呢？本篇文章将带领大家一起在云上借助 ASK 容器服务 + EB 能力构建一套完整的事件驱动架构。

本篇文章以“在线文件解压场景”为例为大家展示经典 EDA 事件驱动与容器如何搭配使用。

关注【Apache RocketMQ】公众号，获取更多相关信息！

服务架构

在线文件解压以 EB OSS 事件通知为驱动点，架构方案如下：

EDA 架构的核心是对事件的应用，OSS 事件默认可以通过云服务总线完成采集，自定义通知事件。本场景是通过 EventBridge 把 OSS 上传文件的事件实时传递给 ASK 中的服务，然后 ASK 中的服务对上传的 ZIP 文件进行下载、解压和再次回传到 OSS。

用到的云服务：

ASK：Serverless 容器服务是一款基于阿里云弹性计算基础架构，同时完全兼容 Kubernetes 生态，安全、可靠的容器产品。

EB：EventBridge 事件总线是一款无服务器事件总线服务，支持阿里云服务、自定义应用、SaaS 应用的事件接入，适用于轻松构建松耦合、分布式的事件驱动架构。

OSS：对象存储服务，提供海量、安全、低成本、高可靠的云存储服务。

场景实践

OSS、ASK 以及 EventBridge 三个云产品的操作步骤如下：

OSS 资源配置

在 OSS 控制台创建相关地域的 Bucket，并记住 Bucket 路径信息。

zip：放置需要解压的zip包

unzip：放置解压后的文件

创建一个可以操作 OSS 文件的用户，并生成 ak/sk 。

打开 RAM 控制台^[^1]，点击「创建用户」。

输入「登陆名称」和「显示名称」并勾选「Open API 调用访问」然后点击确定即可创建一个用户身份。

创建好账号以后再打开 RAM 控制台^[^1]能看到刚才创建的账号信息。

点击账号名称，然后来到账号详情页面。点击「创建 AccessKey」。

然后就能生成 ak、sk 信息，如下所示。保存这两个关键信息，后面配置 ask 解压服务的时候需要使用，也可以点击「下载 CSV 文件」的方式下载下来保存。

有了 ask sk 还不行，要能访问 OSS 服务，还需要给这个子账号授予 OSS 的操作权限，点击「权限管理」。

点击「添加权限」。

在「系统策略」中输入 OSS，然后勾选「AliyunOSSFullAccess」，点击确定即可完成对 OSS 的访问授权。

ASK 资源配置及代码解析

ASK(Serverless Kubernetes) 运行应用程序用于接受来自 EventBridge 发过来的关于 OSS 的事件，所以您首先需要创建一个 ASK 集群，然后部署解压服务。

1）创建 ASK 集群

打开容器服务控制台^[2^]点击右上角的创建集群

选择 ASK 集群

填写集群名称，勾选最下面的《服务协议》，其他都使用默认配置然后就可以创建一个集群出来。

点击右上角的创建，开始创建集群。

弹出确认创建，确认没问题以后点击「确定」即可开始创建。

等几分钟后集群即可创建完成。

如果创建集群过程中遇到问题，可参考创建集群文档^[^3]解决，也可以通过群号 31544226 加钉钉群找答疑解决。

2）部署解压服务

集群部署成功以后点击容器服务页面^[4^]可以看到刚刚创建的集群，然后点击集群名称调转到集群详情页面；

在集群详情页面点击「工作负载」中的「无状态」可以通过提交解压服务 YAML 的方式创建 Deployment 和 Service

点击右上角的「使用 YAML 创建资源」

把下面的 YAML 内容提交上去，注意 OSS_ACCESSKEYID 和 OSS_ACCESSKEYSECRET 这两个环境变量需要设置成你的 ak、sk，并且需要有从 OSS 下载、上传文件的权限。然后点击创建，即可完成服务的创建。

---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: eb-ask-demo
spec:
  selector:
    matchLabels:
      app: eb-ask-demo
  template:
    metadata:
      labels:
        app: eb-ask-demo
    spec:
      containers:
      - name: eb-ask-demo
        image: "registry.cn-hangzhou.aliyuncs.com/kubeway/demo-ossunzip:v0.0.1-20211218152144_master_37323b1"
        resources:
          limits:
            memory: "128Mi"
            cpu: "500m"
        ports:
        - containerPort: 8080
        env:
        - name: OSS_ACCESSKEYID
          value: "ak"
        - name: OSS_ACCESSKEYSECRET
          value: "sk"
        - name: OSS_ENDPOINT
          value: "oss-cn-hangzhou.aliyuncs.com"

解压服务源代码可在 github^[5^] 获取。

3）获取到服务暴露 URL

服务部署好以后点击「网络」中的「服务」即可看到 eb-ask-demo 这个 Service，然后能看到「外部端点」的地址。「外部端点」地址就是解压服务的地址，全路径是 http://121.43.97.107/unzip

EB 资源配置

EB 总线分为云服务总线和自定义总线，云服务总线用于接受云服务事件 E.g. OSS ，自定义总线用于接受自定义事件 E.g. 解压完成信息。

配置云服务总线

配置事件模式，事件模式即事件的筛选规则，需认真配置，否则会造成循环触发。

更多事件模式说明^[6^]参考文末更多链接。

{
    "source": [
        "acs.oss"
    ],
    "type": [
        "oss:ObjectCreated:PostObject",
        "oss:ObjectCreated:UploadPart",
        "oss:ObjectCreated:PutObject",
        "oss:ObjectCreated:UploadPartCopy",
        "oss:ObjectCreated:InitiateMultipartUpload",
        "oss:ObjectCreated:AppendObject",
        "oss:ObjectCreated:CompleteMultipartUpload"
    ],
    "subject": [
        {
            "suffix": ".zip"
        }
    ],
    "data": {
        "oss": {
            "bucket": {
                "name": [
                    "eb-ask"
                ]
            },
            "object": {
                "key": [
                    {
                        "prefix": "zip/"
                    }
                ]
            }
        }
    }
}