Как читать сообщения из очереди aws sqs fifo? - PullRequest
0 голосов
/ 25 июня 2019

Я пытаюсь читать из очереди 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, я пытаюсь прочитать - enter image description here

Я использую следующее в качестве справки -
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

1 Ответ

0 голосов
/ 25 июня 2019

Вы пытались использовать http: // перед именем очереди?Я не использую node.js, но в c # я даю ему весь URL, включая http://

...