对象存储 OSS：通过事件通知实时处理OSS文件变动

您在创建事件通知规则后，若请求者对您OSS进行的操作触发了事件通知规则，SMQ将请求者对OSS进行的相关操作发送到您配置的HTTP服务器或SMQ的队列中。具体流程如下图所示：

OSS的事件通知消息内容经过Base64编码，解码后是JSON格式，具体内容如下：

{"events": [
      {
        "eventName": "",  //事件通知类型。
        "eventSource": "", //设置事件通知的消息源，固定为"acs:oss"。
        "eventTime": "", //事件时间，使用ISO-8601时间表示法。
        "eventVersion": "", //事件通知版本号，目前为“1.0”。
        "oss": {
            "bucket": {
                "arn": "", //Bucket的唯一标识符，格式为"acs:oss:region:uid:bucketname"。
                "name": "", //目标Bucket名称。
                "ownerIdentity": "" //Bucket的拥有者。
            }, 
            "object": {
                "deltaSize": "", //Object大小的变化量。例如，新增一个文件，这个值就是文件大小；覆盖一个文件，这个值就是新文件与旧文件的大小差值，因此可能为负数。
                "eTag": "", //Object的ETag。
                "key": "", //Object名称。
                "position": "", //仅适用于ObjectCreated:AppendObject事件，表示此次请求开始追加的位置。首次AppendObject请求的位置从0字节开始。
                "readFrom": "", //仅适用于ObjectDownloaded:GetObject事件，表示文件开始读取的位置。对于非Range请求，此项为0；对于Range请求，此项为请求的开始字节。
                "readTo": "", //仅适用于ObjectDownloaded:GetObject事件，表示文件最后读取的位置。对于非Range请求，此项为文件的大小；对于Range请求，此项为Range请求的结束字节加1。
                "size": "" //Object大小。
                }, 
        "ossSchemaVersion": "", //此字段域的版本号，目前为“1.0”。
        "ruleId": "GetObject", //此事件匹配的规则ID。
        "region": "", //Bucket所在的地域。
        "requestParameters": {
            "sourceIPAddress": "" //请求的源IP地址。
            }, 
        "responseElements": {
            "requestId": "" //请求对应的Request ID。
            }, 
        "userIdentity": {
            "principalId": "" //请求发起者的UID。
            }, 
        "xVars": {  //OSS的回调功能（Callback）中的自定义参数。
            "x:callback-var1":"value1",
            "x:vallback-var2":"value2"
            }
        }        
     }
  ]
}

消息通知示例：

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