Menggunakan antrian huruf mati untuk menangkap kesalahan peristiwa terenkripsi

Jika Anda mengonfigurasi kunci yang dikelola pelanggan enkripsi pada bus acara, kami sarankan Anda menentukan antrian huruf mati (DLQ) untuk bus acara tersebut. EventBridge mengirimkan acara khusus dan mitra ke DLQ ini jika menemukan kesalahan yang tidak dapat diambil saat memproses acara di bus acara. Kesalahan yang tidak dapat diambil adalah kesalahan di mana tindakan pengguna diperlukan untuk menyelesaikan masalah mendasar, seperti yang ditentukan kunci yang dikelola pelanggan dinonaktifkan atau hilang.

• Jika kesalahan enkripsi atau dekripsi yang tidak dapat diambil terjadi saat EventBridge memproses acara di bus acara, acara dikirim ke DLQ untuk bus acara, jika ada yang ditentukan.

• Jika kesalahan enkripsi atau dekripsi yang tidak dapat diambil terjadi saat EventBridge mencoba mengirim acara ke target, acara dikirim ke DLQ untuk target, jika ada yang ditentukan.

Untuk informasi selengkapnya, termasuk pertimbangan saat menggunakan DLQ, dan petunjuk tentang pengaturan izin, lihat. Menggunakan antrian surat mati untuk memproses peristiwa yang tidak terkirim

Mendekripsi acara dalam EventBridge antrian surat mati

Setelah Anda menyelesaikan masalah mendasar yang menyebabkan kesalahan yang tidak dapat diambil, Anda dapat memproses peristiwa yang dikirim ke bus acara atau DLQ target. Untuk acara terenkripsi, Anda harus terlebih dahulu mendekripsi acara untuk memprosesnya.

Contoh berikut menunjukkan bagaimana untuk mendekripsi acara yang EventBridge telah dikirim ke bus acara atau target DLQ.

// You will receive an encrypted event in the following json format.
        // ```
        //   {
        //     "version": "0", 
        //     "id": "053afa53-cdd7-285b-e754-b0dfd0ac0bfb",  // New event id not the same as the original one
        //     "account": "123456789012",  
        //     "time": "2020-02-10T10:22:00Z",  
        //     "resources": [ ],
        //     "region": "us-east-1",
        //     "source": "aws.events",
        //     "detail-type": "Encrypted Events",
        //     "detail": { 
        //       "event-bus-arn": "arn:aws:events:region:account:event-bus/bus-name", 
        //       "rule-arn": "arn:aws:events:region:account:event-bus/bus-name/rule-name", 
        //       "kms-key-arn": "arn:aws:kms:region:account:key/key-arn", 
        //       "encrypted-payload": "AgR4qiru/XNwTUyCgRHqP7rbbHn/xpmVeVeRIAd12TDYYVwAawABABRhd3M6ZXZlbnRzOmV2ZW50LWJ1cwB
        //                             RYXJuOmF3czpldmVudHM6dXMtZWFzdC0xOjE0NjY4NjkwNDY3MzpldmVudC1idXMvY21rbXMtZ2EtY3Jvc3
        //                             MtYWNjb3VudC1zb3VyY2UtYnVzAAEAB2F3cy1rbXMAS2Fybjphd3M6a21zOnVzLWVhc3QtMToxNDY2ODY5"
        //     }
        //   }
        // ```
 
        // Construct an AwsCrypto object with the encryption algorithm `ALG_AES_256_GCM_HKDF_SHA512_COMMIT_KEY` which 
        // is used by EventBridge for encryption operation. This object is an entry point for decryption operation. 
        // It can later use decryptData(MasterKeyProvider, byte[]) method to decrypt data.
        final AwsCrypto crypto = AwsCrypto.builder()
                .withEncryptionAlgorithm(CryptoAlgorithm.ALG_AES_256_GCM_HKDF_SHA512_COMMIT_KEY)
                .build();
 
        // Construct AWS KMS master key provider with AWS KMS Client Supplier and AWS KMS Key ARN. The KMS Client Supplier can 
        // implement a RegionalClientSupplier interface. The AWS KMS Key ARN can be fetched from kms-key-arn property in 
        // encrypted event json detail.
        final KmsMasterKeyProvider kmsMasterKeyProvider = KmsMasterKeyProvider.builder()
                .customRegionalClientSupplier(...)
                .buildStrict(KMS_KEY_ARN);
 
        // The string of encrypted-payload is base64 encoded. Decode it into byte array, so it can be furthur 
        // decrypted. The encrypted payload can be fetched from encrypted-payload field in encrypted event json detail.
        byte[] encryptedByteArray = Base64.getDecoder().decode(ENCRYPTED_PAYLOAD);
 
        // The decryption operation. It retrieves the encryption context and encrypted data key from the cipher 
        // text headers, which is parsed from byte array encrypted data. Then it decrypts the data key, and 
        // uses it to finally decrypt event payload. This encryption/decryption strategy is called envelope 
        // encryption, https://docs.aws.amazon.com/kms/latest/developerguide/concepts.html#enveloping
        final CryptoResult<byte[], KmsMasterKey> decryptResult = crypto.decryptData(kmsMasterKeyProvider, encryptedByteArray);
 
        final byte[] decryptedByteArray = decryptResult.getResult();
    
        // Decode the event json plaintext from byte array into string with UTF_8 standard.
        String eventJson = new String(decryptedByteArray, StandardCharsets.UTF_8);