Kami mengumumkan yang akan datang end-of-support untuk AWS SDK for JavaScript v2. Kami menyarankan Anda bermigrasi ke AWS SDK for JavaScript v3. Untuk tanggal, detail tambahan, dan informasi tentang cara bermigrasi, silakan merujuk ke pengumuman tertaut.

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

Kami mengumumkan yang akan datang end-of-support untuk AWS SDK for JavaScript v2. Kami menyarankan Anda bermigrasi ke AWS SDK for JavaScript v3. Untuk tanggal, detail tambahan, dan informasi tentang cara bermigrasi, silakan merujuk ke pengumuman tertaut.

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 kode Node.js ini menunjukkan:

Tentang Contoh

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

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 terlebih dahulu menyelesaikan tugas-tugas ini:

Daftar Antrian Anda

Buat modul Node.js 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 daftar antrian Anda, yang secara default adalah objek kosong. Panggil listQueues metode untuk mengambil daftar antrian. Callback mengembalikan URL dari 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 contoh ini dapat ditemukan di sini GitHub.

Membuat Antrian

Buat modul Node.js 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 menyimpan pesan yang diterima. Panggil metode createQueue. Callback 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 contoh ini dapat ditemukan di sini GitHub.

Mendapatkan URL untuk Antrian

Buat modul Node.js 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. Callback 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 contoh ini dapat ditemukan di sini GitHub.

Menghapus Antrian

Buat modul Node.js 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 contoh ini dapat ditemukan di sini GitHub.