Я пытаюсь читать из очереди SQS Fifo, используя javascript SDK, Я использую метод receiveMessage из AWS SQS SDK, чтобы сделать, Но я получаю ошибку при этом.
Ниже приведен фрагмент кода, который я запускаю -
let AWS = require('aws-sdk'); let util = require('util'); AWS.config.update({region: 'us-east-1'}); let test = async() => { let sqs = new AWS.SQS(); let params = { QueueUrl: 'sqs.us-east-1.amazonaws.com/awsAccountId/sqsQueueName.fifo' }; let sqsReceiveMessage = util.promisify(sqs.receiveMessage).bind(sqs); let messages = await sqsReceiveMessage(params); console.log(messages); }; test();
Я получаю следующую ошибку -
(node:13221) UnhandledPromiseRejectionWarning: InvalidAddress: The address sqs.us-east-1.amazonaws.com/awsAccountId/sqsQueueName.fifo is not valid for this endpoint.
Ниже приведен URL-адрес очереди SQS, я пытаюсь прочитать -
Я использую следующее в качестве справки - 1. https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#receiveMessage-property 2. https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html#receiveMessage-property 3. https://www.reddit.com/r/aws/comments/5mclde/sqs_cli_aws_sqs_getqueueurl_returns_different_url/ 4. https://www.bogotobogo.com/DevOps/AWS/aws-Amazon-SQS-Simple-Queue-Service-with-NodeJS-AWS-SDK.php
Вы пытались использовать http: // перед именем очереди?Я не использую node.js, но в c # я даю ему весь URL, включая http://