Kami mengumumkan
Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Menggunakan Antrian Surat Mati di Amazon SQS
Contoh kode Node.js ini menunjukkan:
Cara menggunakan antrian untuk menerima dan menahan pesan dari antrian lain yang tidak dapat diproses antrian.
Skenario
Antrian surat mati adalah antrian yang dapat ditargetkan oleh antrian (sumber) lain untuk pesan yang tidak dapat diproses dengan sukses. Anda dapat menyisihkan dan mengisolasi pesan-pesan ini dalam antrian surat mati untuk menentukan mengapa pemrosesan mereka tidak berhasil. Anda harus mengkonfigurasi secara individual setiap antrian sumber yang mengirim pesan ke antrian huruf mati. Beberapa antrian dapat menargetkan antrian huruf mati tunggal.
Dalam contoh ini, modul Node.js digunakan untuk merutekan pesan ke antrian huruf mati. Modul Node.js menggunakan SDK JavaScript untuk menggunakan antrian huruf mati menggunakan metode kelas klien ini: AWS.SQS
Untuk informasi selengkapnya tentang antrian surat mati Amazon SQS, lihat Menggunakan Antrian Surat Mati Amazon SQS di Panduan Pengembang Layanan Antrian Sederhana Amazon.
Tugas Prasyarat
Untuk mengatur dan menjalankan contoh ini, Anda harus terlebih dahulu menyelesaikan tugas-tugas ini:
Instal Node.js. Untuk informasi selengkapnya tentang menginstal Node.js, lihat situs web Node.js
. Buat file konfigurasi bersama dengan kredensi pengguna Anda. Untuk informasi selengkapnya tentang menyediakan file kredensial bersama, lihat. Memuat Kredensial di Node.js dari File Kredensial Bersama
Buat antrian Amazon SQS untuk berfungsi sebagai antrian surat mati. Untuk contoh membuat antrian, lihatMenggunakan Antrian di Amazon SQS.
Mengkonfigurasi Antrian Sumber
Setelah Anda membuat antrian untuk bertindak sebagai antrian huruf mati, Anda harus mengonfigurasi antrian lain yang merutekan pesan yang belum diproses ke antrian huruf mati. Untuk melakukan ini, tentukan kebijakan redrive yang mengidentifikasi antrian yang akan digunakan sebagai antrian huruf mati dan jumlah maksimum yang diterima oleh masing-masing pesan sebelum dialihkan ke antrian huruf mati.
Buat modul Node.js dengan nama filesqs_deadletterqueue.js
. Pastikan untuk mengkonfigurasi SDK seperti yang ditunjukkan sebelumnya. Untuk mengakses Amazon SQS, buat objek AWS.SQS
layanan. Buat objek JSON yang berisi parameter yang diperlukan untuk memperbarui atribut antrian, termasuk RedrivePolicy
parameter yang menentukan ARN dari antrian huruf mati, serta nilai. maxReceiveCount
Juga tentukan antrian sumber URL yang ingin Anda konfigurasikan. Panggil metode setQueueAttributes
.
// Load the AWS SDK for Node.js var AWS = require("aws-sdk"); // Set the region AWS.config.update({ region: "REGION" }); // Create the SQS service object var sqs = new AWS.SQS({ apiVersion: "2012-11-05" }); var params = { Attributes: { RedrivePolicy: '{"deadLetterTargetArn":"DEAD_LETTER_QUEUE_ARN","maxReceiveCount":"10"}', }, QueueUrl: "SOURCE_QUEUE_URL", }; sqs.setQueueAttributes(params, function (err, data) { if (err) { console.log("Error", err); } else { console.log("Success", data); } });
Untuk menjalankan contoh, ketik berikut ini di baris perintah.
node sqs_deadletterqueue.js
Kode contoh ini dapat ditemukan di sini GitHub