Object Storage Service:イベント通知による OSS オブジェクトのリアルタイム変更処理

イベント通知ルールを作成後、ご利用の OSS バケットに対する操作がそのルールをトリガーすると、SMQ は指定された HTTP サーバーまたは SMQ キューにイベントに関するメッセージを送信します。以下の図はこのプロセスを示しています。

OSS イベント通知には、Base64 エンコードされた JSON ペイロードが含まれています。デコード後のペイロードは、次の構造を持ちます。

{
    "events": [
      {
        "eventName": "",  // イベント通知タイプ。
        "eventSource": "", // イベント通知のソース。この値は固定で "acs:oss" です。
        "eventTime": "", // ISO 8601 形式でのイベント発生時刻。
        "eventVersion": "", // イベント通知のバージョン。現在のバージョンは "1.0" です。
        "oss": {
            "bucket": {
                "arn": "", // バケットの Alibaba Cloud リソースネーム (ARN)。形式："acs:oss:region:uid:bucketname"。
                "name": "", // 送信先バケット名。
                "ownerIdentity": "" // バケットの所有者。
            }, 
            "object": {
                "deltaSize": "", // オブジェクトサイズの変化量。たとえば、新規オブジェクト作成時はオブジェクトサイズ、上書き時は新旧オブジェクトのサイズ差（負の値もあり得る）。
                "eTag": "", // オブジェクトの ETag。
                "key": "", // オブジェクトキー。
                "position": "", // 追加操作の開始位置。このパラメーターは ObjectCreated:AppendObject イベントにのみ適用されます。オブジェクトに対する最初の AppendObject リクエストはバイト 0 から開始されます。
                "readFrom": "", // 読み取り操作の開始位置。このパラメーターは ObjectDownloaded:GetObject イベントにのみ適用されます。範囲指定なしのリクエストでは 0、範囲指定リクエストではリクエストの開始バイト。
                "readTo": "", // 読み取り操作の終了位置。このパラメーターは ObjectDownloaded:GetObject イベントにのみ適用されます。範囲指定なしのリクエストではオブジェクトサイズ、範囲指定リクエストではリクエスト範囲の終了バイト + 1。
                "size": "" // オブジェクトサイズ。
                }, 
        "ossSchemaVersion": "", // このスキーマのバージョン。現在のバージョンは "1.0" です。
        "ruleId": "GetObject", // 一致したイベント通知ルールの ID。
        "region": "", // バケットのリージョン。
        "requestParameters": {
            "sourceIPAddress": "" // リクエストの送信元 IP アドレス。
            }, 
        "responseElements": {
            "requestId": "" // リクエスト ID。
            }, 
        "userIdentity": {
            "principalId": "" // リクエストを行ったユーザーの UID。
            }, 
        "xVars": {  // OSS アップロードコールバック機能におけるカスタムパラメーター。
            "x:callback-var1":"value1",
            "x:callback-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:callback-var2":"value2"
            }
        }        
     }
  ]
}