Batching pesan Amazon SNS

Apa itu batching pesan?

Alternatif untuk memublikasikan pesan ke topik Standar atau FIFO dalam permintaanPublish API individual, adalah menggunakan Amazon SNSPublishBatch API untuk mempublikasikan hingga 10 pesan dalam satu permintaan API. Mengirim pesan dalam batch dapat membantu Anda mengurangi biaya yang terkait dengan menghubungkan aplikasi terdistribusi (pesan A2A) atau mengirim pemberitahuan kepada orang-orang (pesan A2P) dengan Amazon SNS dengan faktor hingga 10. Amazon SNS memiliki kuota tentang berapa banyak pesan yang dapat Anda publikasikan ke topik per detik berdasarkan wilayah tempat Anda beroperasi. Lihat halaman endpoint dan kuota Amazon SNS di Referensi Umum AWSpanduan untuk informasi selengkapnya tentang kuota API.

catatan

Ukuran agregat total semua pesan yang Anda kirim dalam satu permintaanPublishBatch API tidak boleh melebihi 262.144 byte (256 KB).

PublishBatchAPI menggunakan tindakanPublish API yang sama untuk kebijakan IAM.

Bagaimana cara kerja batching pesan?

Menerbitkan pesan denganPublishBatch API mirip dengan menerbitkan pesan denganPublish API. Perbedaan utamanya adalah bahwa setiap pesan dalam permintaanPublishBatch API perlu diberi ID batch unik (hingga 80 karakter). Dengan cara ini, Amazon SNS dapat mengembalikan respons API individual untuk setiap pesan dalam batch untuk mengonfirmasi bahwa setiap pesan dipublikasikan atau bahwa terjadi kegagalan. Untuk pesan yang dipublikasikan ke topik FIFO, selain menyertakan menetapkan ID batch unik, Anda tetap perlu menyertakanMessageDeduplicationID danMessageGroupId untuk setiap pesan individual.

Contoh

Menerbitkan sejumlah 10 pesan ke topik Standar

// Imports
import com.amazonaws.services.sns.AmazonSNS;
import com.amazonaws.services.sns.model.PublishBatchRequest;
import com.amazonaws.services.sns.model.PublishBatchRequestEntry;
import com.amazonaws.services.sns.model.PublishBatchResult;
import com.amazonaws.services.sns.model.AmazonSNSException;
import java.util.List;
import java.util.stream.Collectors;

// Code
private static final int MAX_BATCH_SIZE = 10;

public static void publishBatchToTopic(AmazonSNS snsClient, String topicArn) {
    try {
        // Create the batch entries to send
        List<PublishBatchRequestEntry> entries = IntStream.range(0, MAX_BATCH_SIZE)
                .mapToObj(i -> new PublishBatchRequestEntry()
                        .withId("id" + i)
                        .withMessage("message" + i))
                .collect(Collectors.toList());

        // Create the batch request
        PublishBatchRequest request = new PublishBatchRequest()
                .withTopicArn(topicArn)
                .withPublishBatchRequestEntries(entries);

        // Publish the batch request
        PublishBatchResult publishBatchResult = snsClient.publishBatch(request);

        // Handle the successfully sent messages
        publishBatchResult.getSuccessful().forEach(publishBatchResultEntry -> {
            System.out.println("Batch Id for successful message: " + publishBatchResultEntry.getId());
            System.out.println("Message Id for successful message: " + publishBatchResultEntry.getMessageId());
        });

        // Handle the failed messages
        publishBatchResult.getFailed().forEach(batchResultErrorEntry -> {
            System.out.println("Batch Id for failed message: " + batchResultErrorEntry.getId());
            System.out.println("Error Code for failed message: " + batchResultErrorEntry.getCode());
            System.out.println("Sender Fault for failed message: " + batchResultErrorEntry.getSenderFault());
            System.out.println("Failure Message for failed message: " + batchResultErrorEntry.getMessage());
        });
    } catch (AmazonSNSException e) {
        // Handle any exceptions from the request
        System.err.println(e.getMessage());
        System.exit(1);
    }
}
            

Menerbitkan sejumlah 10 pesan ke topik FIFO

// Imports
import com.amazonaws.services.sns.AmazonSNS;
import com.amazonaws.services.sns.model.PublishBatchRequest;
import com.amazonaws.services.sns.model.PublishBatchRequestEntry;
import com.amazonaws.services.sns.model.PublishBatchResult;
import com.amazonaws.services.sns.model.AmazonSNSException;
import java.util.List;
import java.util.stream.Collectors;

// Code
private static final int MAX_BATCH_SIZE = 10;

public static void publishBatchToFifoTopic(AmazonSNS snsClient, String topicArn) {
    try {
        // Create the batch entries to send
        List<PublishBatchRequestEntry> entries = IntStream.range(0, MAX_BATCH_SIZE)
                .mapToObj(i -> new PublishBatchRequestEntry()
                        .withId("id" + i)
                        .withMessage("message" + i)
                        .withMessageGroupId("groupId")
                        .withMessageDeduplicationId("deduplicationId" + i))
                .collect(Collectors.toList());

        // Create the batch request
        PublishBatchRequest request = new PublishBatchRequest()
                .withTopicArn(topicArn)
                .withPublishBatchRequestEntries(entries);

        // Publish the batch request
        PublishBatchResult publishBatchResult = snsClient.publishBatch(request);

        // Handle the successfully sent messages
        publishBatchResult.getSuccessful().forEach(publishBatchResultEntry -> {
            System.out.println("Batch Id for successful message: " + publishBatchResultEntry.getId());
            System.out.println("Message Id for successful message: " + publishBatchResultEntry.getMessageId());
            System.out.println("SequenceNumber for successful message: " + publishBatchResultEntry.getSequenceNumber());
        });

        // Handle the failed messages
        publishBatchResult.getFailed().forEach(batchResultErrorEntry -> {
            System.out.println("Batch Id for failed message: " + batchResultErrorEntry.getId());
            System.out.println("Error Code for failed message: " + batchResultErrorEntry.getCode());
            System.out.println("Sender Fault for failed message: " + batchResultErrorEntry.getSenderFault());
            System.out.println("Failure Message for failed message: " + batchResultErrorEntry.getMessage());
        });

    } catch (AmazonSNSException e) {
        // Handle any exceptions from the request
        System.err.println(e.getMessage());
        System.exit(1);
    }
}