Описание тега amazon-sqs

Amazon Simple Queue Service (Amazon SQS) предлагает надежную, хорошо масштабируемую размещенную очередь для хранения сообщений при их перемещении между компьютерами.
1 ответ

Файлы процесса помещаются в корзину s3 в лямбда-AWS в том порядке, в котором они были помещены

Мой текущий рабочий процесс выглядит следующим образом: Пользователь помещает файл в s3 bucket -> s3 bucket запускает событие в lambda -> lambda обрабатывает файл в s3 bucket. Это также вызывает другие лямбды. Я хочу разобраться со сценарием, когда …
1 ответ

Невозможно получить сообщения из очереди AWS SQS с помощью Boto

Мой код Python выглядит так: import json import boto.sqs import boto from boto.sqs.connection import SQSConnection from boto.sqs.message import Message from boto.sqs.message import RawMessage sqs = boto.connect_sqs(aws_access_key_id='XXXXXXXXXXXXXXX…
14 сен '15 в 11:58
10 ответов

Тема SNS не публикуется в SQS

Я пытаюсь создать прототип распределенного приложения с использованием SNS и SQS. У меня есть эта тема: arn:aws:sns:us-east-1:574008783416:us-east-1-live-auction и эта очередь: arn:aws:sqs:us-east-1:574008783416:queue4 Я создал очередь, используя JS…
08 май '11 в 10:03
3 ответа

Обработка очередей SQS с помощью boto

У меня есть скрипт на Python, использующий библиотеку boto на экземпляре ec2, который является частью группы автоматического масштабирования. Сценарий обрабатывает сообщения из очереди SQS: import boto from boto.sqs.message import Message conn = bot…
21 июн '12 в 04:58
1 ответ

В стеке нет ошибки на экземпляре ec2, но нормально работает на локальном

Я получаю исключение ниже, и я не получаю никакого решения для решения проблемы. Кроме того, если вы хотите знать, я использую зависимость Amazon Cloud sqs в моем файле Gradle. Любая помощь будет оценена. Caused by: org.springframework.beans.factory…
2 ответа

AWS SQS: задержка предоставления доступа к сообщению, которое не удалось обработать

Вот мой сценарий: У меня есть очередь SQS, которая обрабатывает ряд задач. Эти задачи могут, и часто это не удается. Их провал является обычным и несколько ожидаемым. Когда задача не выполняется, я хочу повторить ее через определенное время, и после…
08 сен '15 в 18:48
1 ответ

Spring AWS SQS переподключается после потери соединения

Я использую Spring Cloud AWS (1.0.1.RELEASE) с Spring Boot для запуска потребителя SQS. Приложение работает нормально, но когда оно теряет сетевое соединение (например, если я выключаю свой WIFI на своем ноутбуке, когда он работает на нем), я вижу о…
3 ответа

Ведение журнала SQS для вставки и удаления из очереди

Я использую Amazon SQS для своего приложения в контексте производителя / потребителя. Я хочу включить ведение журнала на уровне очереди, чтобы видеть элементы, помещенные в очередь и удаленные из нее позже. Как я могу это сделать? Я прочитал следующ…
13 дек '16 в 00:54
1 ответ

AWS sqs отправляет пакетное сообщение от cli

Я пытаюсь отправить пакет сообщений из командной строки, используя aws cli. Команда выглядит так: aws sqs send-message-batch \ --queue-url https://sqs.us-west-2.amazonaws.com/... \ --region=us-west-2 \ --cli-input-json "[{\"Id\":\"1\",\"MessageBody\…
29 июл '16 в 12:20
1 ответ

Лямбда-разработка в AWS -? развиваться локально? или используйте веб-консоль AWS

Как люди развиваются обычно? Используют ли они что-то вроде безсерверного или AWS Lambda (веб-консоль на платформе AWS). Я сталкиваюсь с проблемами при тестировании на локальном компьютере, особенно при моделировании триггера SQS для Lambda и SES. Я…
1 ответ

Монго не находит вставленные данные из вторичного

Мой монго имеет 2 осколка, и каждый осколок имеет 1 основной и 3 второстепенных. Мой сервис записывает данные в первичную систему, а другой работник (работник SQS) запрашивает у Монго последние введенные данные. Но часто он не может найти эти данные…
05 июн '17 в 04:56
2 ответа

Spring Cloud SQS @MessageMapping требует постоянного

Я использую аннотацию @MessageMapping для опроса моей очереди SQS. Никаких проблем здесь, однако. У меня есть общий вопрос об изменении имени очереди в зависимости от среды приложения. Допустим, что локально в моей тестовой среде я хочу, чтобы моя а…
5 ответов

Удаление сообщения из очереди SQS FIFO: срок действия маркера получения истек

Я переключился на очередь FIFO и получил это сообщение об ошибке при попытке удалить сообщение из очереди Value {VALUE} for parameter ReceiptHandle is invalid. Reason: The receipt handle has expired. Похоже, что ошибка происходит, потому что я пытал…
09 окт '17 в 07:22
2 ответа

Работа с Amazon SQS & SNS в Java

Впервые я столкнулся с Amazon SQS и Amazon SNS. Я буду работать с ними на моем рабочем месте в Java. У меня есть несколько вопросов по этому поводу, Я не обладаю таким большим знанием Java, я не могу сказать, что я продвинулся так далеко, но да, я м…
1 ответ

Как создать политику IAM для очередей SQS для определенной идентификации Cognito

Я пытаюсь создать политику IAM для применения к очереди SQS. Политика должна ограничивать доступ к очереди одним федеративным удостоверением Cognito. Я нашел эту ссылку от Amazon на том, как этого добиться, но у меня возникли проблемы с применением …
1 ответ

Можно ли узнать, было ли получено сообщение раньше?

При просмотре свойств сообщения SQS указано ли какое-либо из свойств сообщения, было ли это сообщение получено ранее? Я вижу, что сообщение имеет свойства: Message Id receipthandle md5ofBody тело список атрибутов ключ / значение Исходя из вышесказан…
06 фев '17 в 16:21
2 ответа

Почему Amazon sqs не поддерживает транзакции?

Весной Rabbitmq поддерживает транзакции. Однако Amazon sqs не поддерживает транзакции в Spring. Мне жаль. Я добавил еще немного контента. Я протестировал две очереди сообщений (rabbitmq, amazon sqs), как показано ниже весной. Моя цель - логика обраб…
1 ответ

API-сервер - служба очереди против локальной мини-очереди

Я создал сервер API в узле js, который должен работать под большой нагрузкой. В основном я хочу накапливать входящие запросы на вставку небольшими партиями (по 10 штук в каждом), и после заполнения пакета вставлять эти элементы в базу данных. В наст…
03 авг '16 в 20:15
3 ответа

Тайм-аут видимости RabbitMQ

Есть ли в очередях RabbitMQ AWS SQS-like - "тайм-аут видимости сообщения"? Из документации AWS SQS: "Часы тайм-аута видимости начинают тикать, когда Amazon SQS возвращает сообщение. В течение этого времени компонент обрабатывает и удаляет сообщение.…
16 окт '13 в 18:15
1 ответ

Получить атрибуты очереди не работает

Я пытаюсь получить приблизительное количество сообщений, доступных в настоящее время в очереди SQS. Согласно документации, мне нужно использовать getQueueAttributes, но я не могу заставить его работать. Что я делаю неправильно? var params = { QueueU…