Azure kuyruğu Depolama nasıl kullanılır Node.js

1. npm install @azure/storage-queueKomut penceresine yazın.

2. Bir node_modules klasörün oluşturulduğunu doğrulayın. Bu klasörün içinde @azure/storage-queue , depolamaya erişmeniz gereken istemci kitaplığını içeren paketi bulacaksınız.

1. npm install azure-storageKomut penceresine yazın.

2. Bir node_modules klasörün oluşturulduğunu doğrulayın. Bu klasörün içinde, azure-storage depolamaya erişmeniz gereken kitaplıkları içeren paketi bulacaksınız.

const { QueueClient, QueueServiceClient } = require("@azure/storage-queue");

var azure = require('azure-storage');

Aşağıdaki kod, adlı bir ortam değişkeninin değerini alır AZURE_STORAGE_CONNECTION_STRING ve bunu bir nesne oluşturmak için kullanır QueueServiceClient . Bu nesne daha sonra QueueClient belirli bir kuyruk ile çalışmanıza izin veren bir nesne oluşturmak için kullanılır.

// Retrieve the connection from an environment
// variable called AZURE_STORAGE_CONNECTION_STRING
const connectionString = process.env.AZURE_STORAGE_CONNECTION_STRING;

// Create a unique name for the queue
const queueName = "myqueue-" + Date.now().toString();

console.log("Creating queue: ", queueName);

// Instantiate a QueueServiceClient which will be used
// to create a QueueClient and to list all the queues
const queueServiceClient = QueueServiceClient.fromConnectionString(connectionString);

// Get a QueueClient which will be used
// to create and manipulate a queue
const queueClient = queueServiceClient.getQueueClient(queueName);

// Create the queue
await queueClient.create();

Sıra zaten varsa, bir özel durum oluşturulur.

azure modülü, ortam değişkenlerini AZURE_STORAGE_ACCOUNT ve AZURE_STORAGE_ACCESS_KEY veya AZURE_STORAGE_CONNECTION_STRING azure Depolama hesabınıza bağlanmak için gereken bilgileri okuyacaktır. Bu ortam değişkenleri ayarlanmamışsa, çağırırken hesap bilgilerini belirtmeniz gerekir createQueueService .

Aşağıdaki kod QueueService , kuyruklar ile çalışmanıza olanak sağlayan bir nesnesi oluşturur.

var queueSvc = azure.createQueueService();

createQueueIfNotExistsBelirtilen ada sahip yeni bir sıra oluşturmak veya zaten varsa kuyruğu döndürmek için yöntemini çağırın.

queueSvc.createQueueIfNotExists('myqueue', function(error, results, response){
  if(!error){
    // Queue created or exists
  }
});

Sıra oluşturulduysa, result.created doğru olur. Sıra varsa, result.created false olur.

Bir kuyruğa ileti eklemek için sendMessage yöntemini çağırın.

messageText = "Hello, World";
console.log("Adding message to the queue: ", messageText);

// Add a message to the queue
await queueClient.sendMessage(messageText);

Bir kuyruğa ileti eklemek için, createMessage Yeni bir ileti oluşturmak ve kuyruğa eklemek üzere yöntemini çağırın.

queueSvc.createMessage('myqueue', "Hello, World", function(error, results, response){
  if(!error){
    // Message inserted
  }
});

Varsayılan olarak peekMessages tek bir iletiye göz atar. Aşağıdaki örnekte kuyruktaki ilk beş ileti göz atar. Beşten az ileti görünür durumdaysa, yalnızca görünür iletiler döndürülür.

// Peek at messages in the queue
const peekedMessages = await queueClient.peekMessages({ numberOfMessages: 5 });

for (i = 0; i < peekedMessages.peekedMessageItems.length; i++) {
    // Display the peeked message
    console.log("Peeked message: ", peekedMessages.peekedMessageItems[i].messageText);
}

Varsayılan olarak peekMessages tek bir iletiye göz atar.

queueSvc.peekMessages('myqueue', function(error, results, response){
  if(!error){
    // Message text is in results[0].messageText
  }
});

resultİletiyi içerir.

Çağırarak kuyruktaki bir iletinin içeriğini değiştirme updateMessage .

// Get the first message in the queue
var receivedMessages = await queueClient.receiveMessages();
const firstMessage = receivedMessages.receivedMessageItems[0];

// Update the received message
await queueClient.updateMessage(
    firstMessage.messageId,
    firstMessage.popReceipt,
    "This message has been updated"
);

Çağırarak kuyruktaki bir iletinin içeriğini değiştirme updateMessage .

queueSvc.getMessages('myqueue', function(error, getResults, getResponse){
  if(!error){
    // Got the message
    var message = getResults[0];
    queueSvc.updateMessage('myqueue', message.messageId, message.popReceipt, 10, {messageText: 'new text'}, function(error, updateResults, updateResponse){
      if(!error){
        // Message updated successfully
      }
    });
  }
});

Bir ileti almak için receiveMessages yöntemini çağırın. Bu çağrı, iletileri kuyrukta görünmez hale getirir, dolayısıyla başka hiçbir istemci bunları işleyemez. Uygulamanız bir iletiyi işledikten sonra sıradan silme çağrısı yapın deleteMessage .

// Get next message from the queue
receivedMessages = await queueClient.receiveMessages();
var message = receivedMessages.receivedMessageItems[0];

console.log("Dequeuing message: ", message.messageText);

await queueClient.deleteMessage(message.messageId, message.popReceipt);

Varsayılan olarak, bir ileti yalnızca 30 saniye gizli olur. 30 saniye sonra diğer istemcilere görünür olur. ' İ çağırdığınızda, farklı bir değer belirtebilirsiniz options.visibilityTimeout receiveMessages .

receiveMessagesKuyrukta hiçbir ileti olmadığında çağrı bir hata döndürmez. Ancak, hiçbir ileti döndürülmeyecektir.

Bir ileti almak için getMessages yöntemini çağırın. Bu çağrı, iletileri kuyrukta görünmez hale getirir, dolayısıyla başka hiçbir istemci bunları işleyemez. Uygulamanız bir iletiyi işledikten sonra sıradan silme çağrısı yapın deleteMessage .

queueSvc.getMessages('myqueue', function(error, results, response){
  if(!error){
    // Message text is in results[0].messageText
    var message = results[0];
    queueSvc.deleteMessage('myqueue', message.messageId, message.popReceipt, function(error, response){
      if(!error){
        //message deleted
      }
    });
  }
});

Varsayılan olarak, bir ileti yalnızca 30 saniye gizli olur. 30 saniye sonra diğer istemcilere görünür olur. İle kullanarak farklı bir değer belirtebilirsiniz options.visibilityTimeout getMessages .

getMessagesKuyrukta hiçbir ileti olmadığında kullanmak bir hata döndürmez. Ancak, hiçbir ileti döndürülmeyecektir.

Bir kuyruktan ileti alımını özelleştirmek için iki yol vardır:

• options.numberOfMessages: Bir toplu ileti alın (32 'e kadar).
• options.visibilityTimeout: Daha uzun veya daha kısa görünürlük zaman aşımı ayarlayın.

Aşağıdaki örnek, receiveMessages tek bir çağrıda beş ileti almak için yöntemini kullanır. Ardından, her iletiyi bir döngü kullanarak işler for . Ayrıca, bu yöntemin döndürdüğü tüm iletiler için geçersiz kılma zaman aşımını beş dakikaya ayarlar.

// Get up to 5 messages from the queue
const receivedMsgsResp = await queueClient.receiveMessages({ numberOfMessages: 5, visibilityTimeout: 5 * 60 });

for (i = 0; i < receivedMsgsResp.receivedMessageItems.length; i++)
{
    message = receivedMsgsResp.receivedMessageItems[i];
    console.log("Dequeuing message: ", message.messageText);
    await queueClient.deleteMessage(message.messageId, message.popReceipt);
}

Bir kuyruktan ileti alımını özelleştirmek için iki yol vardır:

• options.numOfMessages: Bir toplu ileti alın (32 'e kadar).
• options.visibilityTimeout: Daha uzun veya daha kısa görünürlük zaman aşımı ayarlayın.

Aşağıdaki örnek, getMessages tek bir çağrıda 15 ileti almak için yöntemini kullanır. Ardından, her iletiyi bir döngü kullanarak işler for . Ayrıca, bu yöntemin döndürdüğü tüm iletiler için geçersiz kılma zaman aşımını beş dakikaya ayarlar.

queueSvc.getMessages('myqueue', {numOfMessages: 15, visibilityTimeout: 5 * 60}, function(error, results, getResponse){
  if(!error){
    // Messages retrieved
    for(var index in results){
      // text is available in result[index].messageText
      var message = results[index];
      queueSvc.deleteMessage(queueName, message.messageId, message.popReceipt, function(error, deleteResponse){
        if(!error){
          // Message deleted
        }
      });
    }
  }
});

yöntemi getProperties kuyrukta bekleyen yaklaşık ileti sayısı da dahil olmak üzere kuyrukla ilgili meta verileri döndürür.

const properties = await queueClient.getProperties();
console.log("Approximate queue length: ", properties.approximateMessagesCount);

yöntemi getQueueMetadata kuyrukta bekleyen yaklaşık ileti sayısı da dahil olmak üzere kuyrukla ilgili meta verileri döndürür.

queueSvc.getQueueMetadata('myqueue', function(error, results, response){
  if(!error){
    // Queue length is available in results.approximateMessageCount
  }
});

Kuyrukların listesini almak için çağrısında QueueServiceClient.listQueues bulundu. Belirli bir ön eke göre filtrelenmiş bir listeyi almak için çağrısında options.prefix'i listQueues ayarlayın.

for await (const item of queueServiceClient.listQueues()) {
  console.log("Queue: ", item.name);
}

Kuyruk listesini almak için listQueuesSegmented kullanın. Belirli bir ön eke göre filtrelenmiş bir liste almak için listQueuesSegmentedWithPrefix kullanın.

queueSvc.listQueuesSegmented(null, function(error, results, response){
  if(!error){
    // results.entries contains the list of queues
  }
});

Tüm kuyruklar döndürülene ise, daha fazla sonuç almak için ilk parametresi veya result.continuationToken listQueuesSegmented ikinci parametresi olarak listQueuesSegmentedWithPrefix iletin.

Bir kuyruğu ve içinde yer alan tüm iletileri silmek için DeleteQueue nesnesinde yöntemini QueueClient çağırmanız gerekir.

// Delete the queue
console.log("Deleting queue: ", queueClient.name);
await queueClient.delete();

Bir kuyruktan silmeden tüm iletileri temizlemek için çağrısında bulundu. ClearMessages

Bir kuyruğu ve içinde yer alan tüm iletileri silmek için kuyruk deleteQueue nesnesinde yöntemini arayın.

queueSvc.deleteQueue(queueName, function(error, response){
  if(!error){
    // Queue has been deleted
  }
});

Bir kuyruktan silmeden tüm iletileri temizlemek için çağrısında bulundu. clearMessages