816
魔兽
五步玩转事件通知__事件通知使用帮助_控制台使用帮助_消息服务-阿里云
事件通知概述,请参考介绍
示例:
某个用户创建了一个Bucket:event-notification-test,然后他关心有哪些Object被上传到这个Bucket中了,他想把事件通知消息推送到Queue中,然后再慢慢消费,于是他就可以创建下面这样的事件通知规则:
- 规则名称:event-notification-test-rule
- 资源描述:event-notification-test/
- 事件类型:PutObject、PostObject
- 接收终端:event-notification-test-queue
五步玩转事件通知:
- Step1. 创建Bucket
- Step2. 创建消息接收的Queue
- Step3. 创建事件通知规则
- Step4. 上传Object
- Step5. 查看Queue中是否接收到消息
Step1. 创建Bucket
- 登录阿里云官网,进入OSS控制台,点击“新建Bucket”,再依次填入BucketName:“event-notification-test”以及选择所属地域:“华南1”(此处方便测试可以设置读写权限为公共读写),如下:
Step2. 创建消息接收的Queue
- 进入MNS控制台,选择“华南1”区域,点击“创建队列”,再依次输入队列名称:“event-notification-test-queue”,选择地域:“华南1”,其他按默认值即可,如下:
Step3. 创建事件通知规则
- 依然保持在MNS控制台,选择左边标签页:“事件通知”,点击“创建规则”,再依次输入规则名称:“event-notification-test-rule”、添加资源(点击“添加”按钮)、选择事件类型(可以多选)以及添加接收终端,如下图:
- 其中资源描述稍微复杂一些,可以参考资源描述后面的问号“?”,其中给了Tips,摘录如下(特别注意:资源描述不能有交集):
资源描述可以是全名、前缀、后缀以及前后缀,不同资源描述不能有交集。
OSS资源包括Bucket和Object,通过“/”连接。
以Bucket(movie)和Object(hello.avi)为例。
1.全名:movie/hello.avi;
2.前缀:
movie/hello,表示movie中以hello为前缀的所有Object,
movie/,表示movie中所有的Object,
mov,表示以mov为前缀的所有Bucket中的所有Object;
3.后缀:.avi,表示所有Bucket中以.avi为后缀的Object;
4.前后缀:前movie/,后.avi,表示movie中所有以.avi为后缀的Object。
- 接收端目前支持HttpServer以及Queue两种,此处我们选择Step2.中创建的Queue。
- 创建一条新规则后,MNS会自动创建一个Topic,并且以指定的Endpoint创建订阅,可以从MNS控制台发布订阅的标签页进行查看,并且可以自由管理这些Topic与Subscription(比如创建新的订阅)。
- 新规则创建完成后,需要约10分钟的时间才能生效。
Step4. 上传Object
- 新规则创建成功10分钟后,回到OSS控制台,尝试上传Object到Step1.创建的Bucket:“event-notification-test”中,验证是否能够触发事件通知。在OSS控制台选中“event-notification-test”,再点击左侧标签页的Object管理,然后在该标签页上传Object,如下图:
Step5. 查看Queue中是否接收到消息
- 上传Object成功后,回到MNS控制台,选中左侧标签页“队列”,并选中区域:“华南1”,查看Step2.创建的队列中的活跃消息数是否为1,并可以点击“接收消息”,查看推送过来的具体事件通知消息。同时,在发布订阅标签页中,也可以看到Topic中多了一条消息,至此可验证事件通知成功。如下图:
- 推送的事件通知消息内容如下,其具体含义可参考Here:
{"events": [{ "eventName": "ObjectCreated:PutObject", "eventSource": "acs:oss", "eventTime": "2016-07-05T15:07:59.000Z", "eventVersion": "1.0", "oss": { "bucket": { "arn": "acs:oss:cn-shenzhen:12345:event-notification-test", "name": "event-notification-test", "ownerIdentity": "12345"}, "object": { "deltaSize": 0, "eTag": "D41D8CD98F00B204E9800998ECF8427E", "key": "a", "size": 0}, "ossSchemaVersion": "1.0", "ruleId": "event-notification-test-rule"}, "region": "cn-shenzhen", "requestParameters": {"sourceIPAddress": "140.205.128.107"}, "responseElements": {"requestId": "577BCD4FF3D45CE477F2FA94"}, "userIdentity": {"principalId": "1390402650033793"}}]}
最后更新:2016-11-23 16:04:14
上一篇:
获取订阅属性__主题使用帮助_控制台使用帮助_消息服务-阿里云
下一篇:
默认规则事件通知__事件通知使用帮助_控制台使用帮助_消息服务-阿里云
Spark + ONS__Spark_开发人员指南_E-MapReduce-阿里云
查询实例列表__实例相关接口_API 参考_云服务器 ECS-阿里云
查询已发布API详情__API管理相关接口_API_API 网关-阿里云
公共云与金融云间的数据迁移__最佳实践_数据传输-阿里云
SSH 连接时出现如下错误:pam_limits(sshd:session):could not sent limit for 'nofile'__远程登录 (SSH)_Linux操作运维问题_云服务器 ECS-阿里云
RouteTableSetType__数据类型_API 参考_云服务器 ECS-阿里云
DRDS慢SQL明细__开发手册_分布式关系型数据库 DRDS-阿里云
产品名词解释__产品简介_批量计算-阿里云
AccessPointSetType__数据类型_API 参考_云服务器 ECS-阿里云
数据安全和用户隐私是第一原则 阿里云发布首个企业云安全架构
相关内容
常见错误说明__附录_大数据计算服务-阿里云
发送短信接口__API使用手册_短信服务-阿里云
接口文档__Android_安全组件教程_移动安全-阿里云
运营商错误码(联通)__常见问题_短信服务-阿里云
设置短信模板__使用手册_短信服务-阿里云
OSS 权限问题及排查__常见错误及排除_最佳实践_对象存储 OSS-阿里云
消息通知__操作指南_批量计算-阿里云
设备端快速接入(MQTT)__快速开始_阿里云物联网套件-阿里云
查询API调用流量数据__API管理相关接口_API_API 网关-阿里云
使用STS访问__JavaScript-SDK_SDK 参考_对象存储 OSS-阿里云