轻量消息队列（原 MNS）：对象存储OSS

适用场景

• 当您授权其他用户对您的资源（Bucket）进行某些操作的权限，且希望关注这些操作，可以通过创建规则，在这些操作发生时主动通知您。

• 通过事件通知的方式进行数据分析、查看一段时间内某个操作发生的次数，分析您的业务最近的发展趋势。您还可以将这些事件通知的消息导入其他服务，例如EMR，进一步进行自定义分析。

• 通过事件通知监控您的资源上发生的某些操作的QPS等指标。

事件类型

消息格式

对象存储OSS的事件通知消息内容是经过Base64编码的，解码后是JSON格式，示例代码如下所示。

{
    "events":[
        {
            "eventName":"ObjectDownloaded:GetObject",
            "eventSource":"acs:oss",
            "eventTime":"2016-07-01T11:17:30.000Z",
            "eventVersion":"1.0",
            "oss":{
                "bucket":{
                    "arn":"acs:oss:cn-shenzhen:123456789098****:event-notification-test-shenzhen",
                    "name":"event-notification-test-shenzhen",
                    "ownerIdentity":"123456789098****"
                },
                "object":{
                    "deltaSize":0,
                    "eTag":"0CC175B9C0F1B6A831C399E26977****",
                    "key":"test",
                    "readFrom":0,
                    "readTo":1,
                    "size":1
                },
                "ossSchemaVersion":"1.0",
                "ruleId":"GetObjectRule"
            },
            "region":"cn-shenzhen",
            "requestParameters":{
                "sourceIPAddress":"140.205.XX.XX"
            },
            "responseElements":{
                "requestId":"5776514AF09A9E654242****"
            },
            "userIdentity":{
                "principalId":"123456789098****"
            },
            "xVars":{
                "x:callback-var1":"value1",
                "x:vallback-var2":"value2"
            }
        }
    ]
}

参数解释如下所示。

注意事项

• 事件通知规则创建完成后，约10分钟生效。

• 系统会自动为新建的规则创建主题，主题可能产生费用，详情请参见计费说明。

• 事件通知规则支持创建和删除，暂时不支持修改。

步骤一：创建队列

1. 登录轻量消息队列（原 MNS）控制台。

2. 在左侧导航栏，选择队列模型 > 队列列表。

3. 在顶部菜单栏，选择地域。

4. 在队列列表页面，单击创建队列。

5. 在创建队列面板配置以下参数，然后单击确定。

   • 名称：队列名称。

   • 消息最大长度：发送到队列的消息体的最大长度。

   • 长轮询时间：当队列中没有消息时，该队列的ReceiveMessage请求的最大等待时长。

   • 消息可见性超时时间：消息从队列中取出后从Active状态变成Inactive状态后的持续时间。

   • 消息保存时长：消息在队列中的最长存活时间。从发送到队列开始经过此参数指定的时间后，不论消息是否被取出都将被删除。

   • 消息定时时间：发送到队列的所有消息将延后此参数指定的时间后被消费。

   • 启用日志功能：是否开启日志管理功能。

   队列列表页面目标队列已创建。

步骤二：创建Bucket

1. 登录OSS管理控制台。

2. 在左侧导航栏，单击Bucket列表。

3. 在Bucket列表页面，单击创建Bucket。

4. 在创建 Bucket面板，配置Bucket参数，然后单击确定。

   • Bucket 名称：输入event-notification-test。

   • 地域：跟队列所在的地域保持一致。

   • 阻止公共访问：不开通

   • 读写权限：选择公共读写。

     说明

     其他配置项请保持默认。

步骤三：创建自定义规则

创建一个新规则后，轻量消息队列（原 MNS）会自动创建一个主题，并且以指定的Endpoint创建订阅。您可以在轻量消息队列（原 MNS）控制台查看和管理这些主题与订阅（例如创建新的订阅）。

1. 登录轻量消息队列（原 MNS）控制台。

2. 在左侧导航栏，单击事件通知。

3. 在顶部菜单栏，选择地域。

4. 在事件通知页面，单击对象存储OSS页签， 然后单击创建规则。

5. 在创建规则-对象存储OSS面板，进行以下配置，然后单击确定。

   • 名称：输入规则名称。

   • 事件类型：选择事件类型。

   • 匹配规则：设置匹配规则。

     说明

     匹配规则可以是全名、前缀、后缀以及前后缀，不同规则不能有交集。OSS资源包括Bucket和Object，通过“/”连接。例如：资源movie/hello.avi由Bucket（movie）和Object（hello.avi）组成。

     • 全名：movie/hello.avi。

     • 前缀：

       • movie/hello：movie中以hello为前缀的Object。

       • movie/：Bucket名称为movie的所有的Object。

       • mov：Bucket名称前缀为mov的所有Object。

     • 后缀：.avi：所有Bucket中以.avi为后缀的Object。

     • 前后缀：前缀movie/，后缀.avi：movie中所有以.avi为后缀的Object。

   • 接收终端：选择队列，输入步骤一中创建的队列名称。

步骤四：上传Object

1. 登录OSS管理控制台。

2. 在左侧导航栏，单击Bucket列表。

3. 在Bucket列表页面，单击Bucket名称列下的目标Bucket。

4. 选择文件管理 > 文件列表，然后单击上传文件。

5. 在上传文件面板，配置文件上传目录和文件ACL，单击上传文件。更多配置参数信息，请参见使用OSS控制台上传文件。

   状态列显示：上传成功。

步骤五：接收消息

1. 登录轻量消息队列（原 MNS）控制台。

2. 在左侧导航栏，选择队列模型 > 队列列表。

3. 在顶部菜单栏，选择地域。

4. 在队列列表页面，找到目标队列，在其右侧操作列选择更多 > 收发消息。

5. 在队列收发消息快速体验页面的接收消息区域，单击接收消息。

   接收消息区域显示队列的消息列表。

6. 在消息列表中，找到目标消息，在其右侧操作列单击详情，在消息详情对话框中查看消息内容。