AWS SDK untuk JavaScript V2 telah mencapai akhir dukungan. Kami menyarankan Anda bermigrasi ke AWS SDK untuk JavaScript v3. Untuk detail dan informasi tambahan tentang cara bermigrasi, silakan lihat pengumuman ini.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Menggunakan Antrian di Amazon SQS

Contoh Node.js kode ini menunjukkan:

Tentang Contoh

Dalam contoh ini, serangkaian Node.js modul digunakan untuk bekerja dengan antrian. Node.js Modul menggunakan SDK for JavaScript untuk mengaktifkan antrian untuk memanggil metode berikut dari kelas AWS.SQS klien:

Untuk informasi selengkapnya tentang pesan Amazon SQS, lihat Cara Kerja Antrian di Panduan Pengembang Layanan Antrian Sederhana Amazon.

Tugas Prasyarat

Untuk mengatur dan menjalankan contoh ini, Anda harus menyelesaikan tugas ini terlebih dahulu:

Daftar Antrian Anda

Buat Node.js modul dengan nama filesqs_listqueues.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 membuat daftar antrian Anda, yang secara default adalah objek kosong. Panggil listQueues metode untuk mengambil daftar antrian. Panggilan balik mengembalikan URL semua antrian.

// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var params = {};

sqs.listQueues(params, function (err, data) {
  if (err) {
    console.log("Error", err);
  } else {
    console.log("Success", data.QueueUrls);
  }
});

Untuk menjalankan contoh, ketik berikut ini di baris perintah.

node sqs_listqueues.js

Kode sampel ini dapat ditemukan di sini GitHub.

Membuat Antrian

Buat Node.js modul dengan nama filesqs_createqueue.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 membuat daftar antrian Anda, yang harus menyertakan nama untuk antrian yang dibuat. Parameter juga dapat berisi atribut untuk antrian, seperti jumlah detik pengiriman pesan tertunda atau jumlah detik untuk mempertahankan pesan yang diterima. Panggil metode createQueue. Panggilan balik mengembalikan URL antrian yang dibuat.

// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var params = {
  QueueName: "SQS_QUEUE_NAME",
  Attributes: {
    DelaySeconds: "60",
    MessageRetentionPeriod: "86400",
  },
};

sqs.createQueue(params, function (err, data) {
  if (err) {
    console.log("Error", err);
  } else {
    console.log("Success", data.QueueUrl);
  }
});

Untuk menjalankan contoh, ketik berikut ini di baris perintah.

node sqs_createqueue.js

Kode sampel ini dapat ditemukan di sini GitHub.

Mendapatkan URL untuk Antrian

Buat Node.js modul dengan nama filesqs_getqueueurl.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 membuat daftar antrian Anda, yang harus menyertakan nama antrian yang URL-nya Anda inginkan. Panggil metode getQueueUrl. Panggilan balik mengembalikan URL antrian yang ditentukan.

// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var params = {
  QueueName: "SQS_QUEUE_NAME",
};

sqs.getQueueUrl(params, function (err, data) {
  if (err) {
    console.log("Error", err);
  } else {
    console.log("Success", data.QueueUrl);
  }
});

Untuk menjalankan contoh, ketik berikut ini di baris perintah.

node sqs_getqueueurl.js

Kode sampel ini dapat ditemukan di sini GitHub.

Menghapus Antrian

Buat Node.js modul dengan nama filesqs_deletequeue.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 menghapus antrian, yang terdiri dari URL antrian yang ingin Anda hapus. Panggil metode deleteQueue.

// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var params = {
  QueueUrl: "SQS_QUEUE_URL",
};

sqs.deleteQueue(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_deletequeue.js

Kode sampel ini dapat ditemukan di sini GitHub.