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": "", // バケットの一意の識別子。形式は "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: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"
            }
        }        
     }
  ]
}