Описание тега aws-sqs-fifo
1
ответ
Действительно ли очередь AWS SQS FIFO является точной - однократная доставка
У меня есть код обработчика функции ниже. public async Task FunctionHandler(SQSEvent evnt, ILambdaContext context) { foreach (var message in @event.Records) { // Do work // If a message processed successfully delete the SQS message // If a message f…
10 май '21 в 23:11
0
ответов
Есть ли способ снова отправить сообщение в SQS (FIFO), если тело сообщения не изменилось (изменились только параметры)?
Есть ли способ снова отправить сообщение в SQS (FIFO), если тело сообщения не изменилось (изменились только параметры)? В настоящее время я не могу снова отправить сообщение в SQS, если атрибут «messageBody» не изменен. Я предполагаю, что очередь пр…
11 май '21 в 12:12
0
ответов
Очередь AWS SQS FIFO
У меня есть очередь AWS SQS fifo для моего проекта laravel. Я пытаюсь понять, как рабочий забирает задания из очереди и как я могу настроить несколько рабочих для очереди fifo. Но когда я проверил своего супервизора, работника нет, но задания все ра…
12 май '21 в 18:37
1
ответ
Как перейти к свойству $ response в AWS SQS SendMessageResult с помощью машинописного текста?
Я отправляю сообщение в очередь SQS следующим образом в машинописном тексте: Во время выполнения SendMessageRequest показывает $responseсвойство, но это не видно в определении объекта. Как лучше всего получить доступ к этому свойству во время выполн…
14 май '21 в 17:06
0
ответов
Как настроить несколько потребителей SQS для одной очереди в приложении Springboot?
Я хочу масштабировать потребителей SQS в приложении Springboot. Прямо сейчас я использую аннотацию @Sqslistner, чтобы получать сообщение только в одном потоке. Я хочу увеличить количество слушателей SQS. Но я не уверен, как использовать @Sqslistner …
20 май '21 в 12:48
0
ответов
AWS - SQS FIFO - сообщение не может быть удалено - дескриптор квитанции истек
Продолжительность опроса - 10 сек. Тайм-аут видимости - 1мин. 1- удаление сообщения во время опроса -> Успех 2- удаление сообщения после завершения опроса, но в течение периода тайм-аута видимости -> Сбой когда я пытаюсь удалить сообщение в т…
03 июн '21 в 08:59
1
ответ
Генерация подписи AWS SQS из java
Мне нужно получить сообщение от AWS SQS с использованием Spring RestTemplate(привязанный прокси) вместо обмена сообщениями aws sdk или spring cloud aws из-за некоторых проблем с прокси-сервером компании. Мне нужно сгенерировать строку заголовка, вкл…
23 июн '21 в 17:01
0
ответов
WSO2 EI 6.5.0 - ОШИБКА нарушения протокола NHTTP при использовании AWS SQS
Я использую AWS SQS Connector (V1.0.7) Операция под названием «SendMessage» с использованием WSo2 EI 6.5.0. При отправке полезной нагрузки в AWS SQS произошла некоторая ОШИБКА. В последовательности ошибок я получаю подробности ниже, Error_message = …
12 июл '21 в 10:58
1
ответ
Моя лямбда-функция не получает события от службы SQS
Я установил лямбда-функцию и службу SQS. Я хочу, чтобы события из службы SQS использовались лямбда-функцией. Конфигурация SQS Все остальные настройки настроены в соответствии с настройками по умолчанию. Лямбда-триггер Конфигурация лямбда Используемы…
20 июл '21 в 12:27
1
ответ
Учитывает ли aws sqs атрибуты сообщения / системные атрибуты, когда включена дедупликация на основе содержимого?
Я работаю над проектом с использованием aws sqs, я хочу использовать дедупликацию на основе содержимого для очередей fifo, но я не смог найти в документации, считает ли sqs атрибуты сообщений и атрибуты системы сообщений как « Content » или нет.
28 июл '21 в 14:21
0
ответов
несколько слушателей sqs, указывающих на одну и ту же очередь sqs fifo
У меня есть приложение springboot, которое прослушивает очередь sqs fifo с использованием spring cloud aws. Приложение кластеризовано и имеет 2 узла. Оба узла слушают одну и ту же очередь, и это приводит к некоторым проблемам с параллелизмом, когда …
05 авг '21 в 08:04
0
ответов
SQS FIFO QUEUE - sqslistener в кластерном приложении Springboot
У меня есть кластерное приложение springboot, обрабатывающее сообщения из очереди sqs fifo. Очередь fifo интегрирована в springboot с использованием аннотации spring @sqslistener. У меня в очереди много записей о сотрудниках. когда одновременно пост…
05 авг '21 в 03:32
1
ответ
Слушатель очереди SQS (Springboot)
Как управлять запросом с помощью SQS. Предположим, что 4 запроса отправлены одновременно в SQS, а затем нужно обрабатывать только по одному. Как только первый завершится, возьмите второй запрос из очереди в процессе, и этот процесс необходимо продол…
11 авг '21 в 21:30
1
ответ
Могу ли я написать в SQS + Lambda логику распределенной обработки внутреннего опросчика Lambda, который считывает сообщения из SQS?
В настоящее время я использую архитектуру триггера SQS(fifo) + Lambda. Каждый раз, когда сообщение отправляется в SQS, функция Lambda создается и обрабатывается внутренним опросчиком. Это совершенно нормальная, типичная логика обработки SQS + Lambda…
23 авг '21 в 09:51
1
ответ
После изменения содержимого тела AWS SQS не сохраняет событие, и появляется ошибка отказа в доступе.
Используя, я пытаюсь сохранить событие в SQS, все работает нормально, просто JSONкак показано ниже, { "subscriptionId": "6d000ba7-9bcb-3e2f-bf2e-e960026f000e", "notificationId": 6, "id": "e8ee798d-c888-4fdd-666a-626627da0f73", "eventType": "workitem…
14 сен '21 в 00:22
0
ответов
Проверка того, было ли сообщение AWS SQS получено очередью и ожидает ли оно чтения слушателем или уже прочитано слушателем
Я новичок в AWS и пытаюсь создать сообщение SQS. Я использую существующий рабочий код. Я вижу в журнале, что сообщение создано успешно. Я регистрирую идентификатор сообщения SendMessageResult для отладки. Теперь я пытаюсь проверить, ожидает ли сообщ…
21 сен '21 в 09:04
0
ответов
Ограничить доступ к SQS только лямбда-функциями с помощью атрибута SQS :: QueuePolicy 'Principal'
У меня есть очередь SQS с этой политикой очереди SQSPolicy: Type: AWS::SQS::QueuePolicy Properties: Queues: - !Ref myQueue PolicyDocument: Statement: - Effect: 'Allow' Principal: '*' Action: - 'SQS:SendMessage' - 'SQS:ReceiveMessage' - 'SQS:DeleteMe…
29 сен '21 в 20:16
1
ответ
очередь с контролем оттока (обратное давление) на AWS
Я хотел бы иметь очередь (FIFO большой емкости), в которую я мог бы помещать элементы, а также контролировать скорость выхода элементов из очереди. Похоже, что SQS скорее фокусируется на обработке элементов в очереди как можно быстрее, без прямого к…
20 сен '21 в 01:21
0
ответов
Снижение пропускной способности AWS lambda с помощью триггера SQS
Наша система различает то, что мы называем «одиночными событиями» и «массовыми событиями». Единичные события являются результатом взаимодействия с пользователем и происходят по нескольку одновременно, время от времени. Массовые события являются резу…
29 сен '21 в 12:17
0
ответов
Время ожидания sendBatchMessage клиента очереди SQS истекло
У меня есть интеграция SQS и Lambda, SQS - это очередь FIFO. Я создаю еще один клиент SQS в методе обработчика лямбда. Согласно функциональной логике, если сообщения недействительны, мы помещаем эти сообщения в эту очередь SQS. SendMessageBatchResul…
11 окт '21 в 22:16