Object Storage Service:イベント通知を使用してオブジェクトの変更をリアルタイムで監視する

OSS リソースに対して実行された操作がイベント通知ルールをトリガーした場合、SMQ は指定された HTTP サーバーまたは SMQ キューに操作に関する通知を送信します。 次の図は、プロセスを詳細に示しています。

OSS イベント通知の内容は Base64 エンコードされています。 コンテンツがデコードされると、コンテンツは JSON 形式になります。 次のサンプルコードは、デコードされたイベント通知コンテンツの例を示しています。

{"events": [
      {
        "eventName": "",  // イベント名
        "eventSource": "", // イベント通知ルールをトリガーするソース。 有効な値：acs:oss。
        "eventTime": "", // イベントが発生した時刻。 時刻は ISO 8601 標準のタイムスタンプです。
        "eventVersion": "", // イベント通知のバージョン。 現在のバージョンは 1.0 です。
        "oss": {
            "bucket": {
                "arn": "", // 次の形式のバケットの Alibaba Cloud Resource Name (ARN)：acs:oss:region:uid:bucketname。
                "name": "", // イベント通知ルールが適用されるオブジェクトを含むバケットの名前。
                "ownerIdentity": "" // バケットの所有者。
            }, 
            "object": {
                "deltaSize": "", // 新しいオブジェクトと元のオブジェクトのサイズの違い。 オブジェクトが作成されると、このパラメーターの値はオブジェクトのサイズを示します。 オブジェクトが上書きされると、値は新しいオブジェクトと元のオブジェクトのサイズの差を示します。 値は負になる場合があります。
                "eTag": "", // オブジェクトの ETag 値。
                "key": "", // オブジェクトの名前。
                "position": "", // AppendObject 操作が開始される位置。 このパラメーターは、ObjectCreated:AppendObject イベントにのみ適用されます。 オブジェクトに対する最初の AppendObject 操作は、オブジェクトのバイト 0 から開始されます。
                "readFrom": "", // GetObject 操作が開始される位置。 このパラメーターは、ObjectDownloaded:GetObject イベントにのみ適用されます。 GetObject 操作が範囲によって実行されない場合、このパラメーターの値は 0 です。 それ以外の場合、値は GetObject 操作が開始されるバイトの位置を参照します。
                "readTo": "", // GetObject 操作が終了する位置。 このパラメーターは、ObjectDownloaded:GetObject イベントにのみ適用されます。 GetObject 操作が範囲によって実行されない場合、このパラメーターの値はオブジェクトサイズです。 それ以外の場合、値は GetObject 操作が終了するバイトの後の最初のバイトの位置を参照します。
                "size": "" // オブジェクトのサイズ。
                }, 
        "ossSchemaVersion": "", // スキーマのバージョン。 現在の値は 1.0 です。
        "ruleId": "GetObject", // イベントによってトリガーされるイベント通知ルールの ID。
        "region": "", // バケットが配置されているリージョン。
        "requestParameters": {
            "sourceIPAddress": "" // リクエストが送信された送信元 IP アドレス。
            }, 
        "responseElements": {
            "requestId": "" // リクエストの ID。
            }, 
        "userIdentity": {
            "principalId": "" // リクエスターの UID。
            }, 
        "xVars": {  // OSS コールバックのカスタムパラメーター。
            "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"
            }
        }        
     }
  ]
}