aws sqsで受信メッセージを確認します

Question

どのようにして受信メッセージが継続的にチェックされますか？次の関数は、メッセージを受け取った後に終了します。キューの長いポーリングが有効になっているため、新しいメッセージを継続的にチェックするにはどうすればよいですか？

function checkMessage(){ 
    var params = { 
       QueueUrl : Constant.QUEUE_URL, 
       VisibilityTimeout: 0, 
       WaitTimeSeconds: 0 
      } 
    sqs.receiveMessage(params,(err,data) => { 
     if(data){ 
      console.log("%o",data); 
     } 
    }); 
} 

Answer 1

あなたの関数は、引き続きAmazon SQSをポーリングする必要があります。

ロングポーリングは、利用可能なメッセージがない場合、応答を最大20秒遅らせます。その期間中にメッセージが利用可能になると、すぐに返されます。 20秒後にメッセージがない場合は、メッセージを提示せずに戻ります。

したがって、関数はSQSを再度ポーリングする必要があります（その間に何か他の処理をしている可能性があります）。

Answer 2

var processMessages = (function (err, data) { 
    if (data.Messages) { 

     for (i = 0; i < data.Messages.length; i++) { 
      var message = data.Messages[i]; 
      var body = JSON.parse(message.Body); 

      // process message 
      // delete if successful 
     } 
    } 
}); 

while (true) { 
    sqs.receiveMessage({ 
     QueueUrl: sqsQueueUrl, 
     MaxNumberOfMessages: 5, // how many messages to retrieve in a batch 
     VisibilityTimeout: 60, // how long until these messages are available to another consumer 
     WaitTimeSeconds: 15  // how many seconds to wait for messages before continuing 
    }, processMessages); 
}