Вопросы по теме 'amazon-sqs'
Эспер и SQS
Мне интересно, пробовал ли кто-нибудь здесь использовать Esper для обработки данных из облака? В частности, Amazon Simple Queuing Service. Я гуглил об этом, и мы знаем, что это возможно, но было бы неплохо узнать, пробовал ли кто-нибудь это. Еще...
663 просмотров
schedule
21.05.2024
Изменить время ожидания видимости для сообщения SQS с помощью ruby aws-sdk [ruby newbie]
Может ли кто-нибудь помочь с примером, как изменить тайм-аут видимости для сообщения sqs с помощью ruby aws-sdk?
вот код, который я использовал для своих тестов с использованием метода batch_change_message_visibility, но я получаю сообщение об...
1399 просмотров
schedule
11.05.2024
Когда следует использовать функцию очереди с задержкой в Amazon SQS?
Я понимаю концепцию очереди задержки в Amazon SQS, но мне интересно, почему она полезна. Каково использование очереди задержки SQS? Спасибо
4489 просмотров
schedule
16.02.2024
Amazon SQS отправляет атрибуты сообщения в php
Мне нужно реализовать отправку сообщений в SQS с атрибутами. Тело сообщения загружается нормально, но у меня проблема с атрибутами. Для атрибутов сообщения требуется ассоциативный массив с именем атрибута, типом данных и значением. Я получил такую...
3418 просмотров
schedule
16.12.2023
Как можно непрерывно материализовать потоки Akka?
Я использую Akka Streams в Scala для опроса из очереди AWS SQS с помощью AWS Java SDK . Я создал ActorPublisher , который удаляет сообщения из очереди через двухсекундный интервал:
class SQSSubscriber(name: String) extends...
1551 просмотров
schedule
16.04.2024
Параметр чтения лямбда-выражения AWS или выходные данные CloudFormation
Выглядит как действительно простая задача, но трудно найти на ней хороший пример. Итак, задача следующая: AWS lambda отправляет какое-то сообщение в AWS-SQS.
Код AWS lambda содержит такую строку:
var QUEUE_URL =...
1566 просмотров
schedule
19.03.2024
JmsListener и SQS
Я настраиваю JMS с помощью spring с помощью org.springframework.jms.annotation.JmsListenerConfigurer.
Я использую Amazon SQS:
amazonSQS().createQueue(queueRequest).getQueueUrl(); endpoint.setMessageListener(agentActionListener());
У меня...
847 просмотров
schedule
10.12.2023
Запускать лямбда-функцию в AWS, когда сообщение присутствует в очереди SQS
Я использую функцию AWS Lambda для обработки сообщений в очереди, она работает нормально. Но мне нужно выполнить эту лямбда-функцию, когда сообщения доступны или добавлены в очередь SQS.
Можно ли активировать лямбда-функцию на основе очереди SQS?...
3690 просмотров
schedule
11.01.2024
Эластичная рабочая среда beanstalk — как понять, почему все сообщения попадают в очередь недоставленных сообщений?
Я только начал использовать рабочую среду в эластичном бобовом стебле. Насколько я понимаю, среда прослушивает очередь, а затем отправляет сообщение по указанному вами URL-адресу. Я создал конечную точку POST и указал URL-адрес в разделе...
356 просмотров
schedule
10.05.2024
Функция AWS Lambda запрашивает SQS MessageId и ApiGateway
Вызов URL-адреса моего шлюза API запускает функцию Lambda, которая вставляет сообщение, переданное в SQS, и возвращает идентификатор сообщения в очереди. Теперь я создал еще один ресурс API Gateway и через другую функцию Lambda распечатал все...
925 просмотров
schedule
10.12.2023
Политика удаления Spring Cloud AWS SQS
У нас есть прослушиватель SQS, например:
@MessageMapping("queueName")
void listen(String message) { ... }
Для этой очереди настроена политика переадресации с соответствующей очередью недоставленных сообщений.
Проблема заключается в том,...
3396 просмотров
schedule
08.12.2023
Как хранить сообщения в очереди SQS дольше 14 дней?
У меня есть очередь, в которой будет огромное количество сообщений, которые будут обрабатываться в течение многих дней. Вполне вероятно, что некоторые из первых сообщений в очереди могут все еще находиться там, ожидая возможности обработки дольше 14...
653 просмотров
schedule
26.10.2022
Использование функций AWS Lambda для использования очередей AWS SQS
Я использую функцию AWS Lambda, которая запускается триггером события SNS для использования из очереди SQS. Когда функция Lambda выполняется, она извлекает 10 сообщений из очереди, обрабатывает их, извлекает еще 10 и т.д. ).
Насколько я понимаю,...
1188 просмотров
schedule
18.11.2022
Ошибка сельдерея / SQS Нет модуля с именем sqs
Я не могу настроить Celery для использования SQS. Я выполнил инструкции по этой ссылке: http://docs.celeryproject.org/en/latest/getting-started/brokers/sqs.html
Вот трассировка стека.
[2018-02-21 12: 27: 25,073: CRITICAL / MainProcess]...
611 просмотров
schedule
28.10.2022
Получение сообщений SQS с помощью лямбда-функции AWS
У меня есть 2 очереди FIFO SQS, которые получают сообщения JSON, которые должны индексироваться в elasticsearch. Одна очередь постоянно добавляет дельта-изменения в базу данных и добавляет их в очередь. Вторая очередь используется для переиндексации...
1421 просмотров
schedule
01.10.2022
Aws::SQS::Errors::NonExistentQueue (Указанная очередь по умолчанию не существует.):
Я создал рабочую машину в AWS и SQS с именем queue123 и использую shoryuken gem в качестве адаптера ( config.active_job.queue_adapter = :shoryuken at application.rb ).
class EmailVerificationMailerJob < ActiveJob::Base
queue_as 'queue123'...
992 просмотров
schedule
06.11.2023
автоматически печатать большое количество PDF-файлов с помощью laravel в фоновом режиме
Мы запускаем наше приложение с Laravel 5.4 с worker, redis и sqs для наших заданий.
Теперь у нас есть запрос функции, где нам нужно напечатать большое количество билетов (около 3000 билетов) в виде пакета. Билеты создаются в формате PDF (размер...
800 просмотров
schedule
23.12.2023
Связь между Glue dpu и максимальным параллелизмом
Я работаю в Amazon EMR более года, но недавно мы перешли на aws glue для обработки данных.
Мне трудно понять взаимосвязь между no of dpus и max concurrency , которую мы обеспечиваем при работе с клеем.
Например, я создал задание с 2 dpus...
8607 просмотров
schedule
21.10.2022
Как обрабатывать более 10 одновременных сообщений из очереди AWS SQS FiFo с помощью Spring Integration
Я хочу иметь возможность обрабатывать более 10 сообщений SQS одновременно с помощью Spring Integration Workflow.
Исходя из этого вопроса, было рекомендовано использовать ExecutorChannel . Я обновил свой код, но симптомы остались прежними.
Как...
1409 просмотров
schedule
20.11.2022
Сообщения исчезают из очереди SQS в Lambda
Я отправляю сообщения из очереди SQS в функцию Node.js Lambda. Я отправляю в очередь около 20 сообщений одновременно, после чего Lambda начинает работать.
Некоторые из этих сообщений никогда не появляются в очереди или, по крайней мере, не...
1477 просмотров
schedule
16.11.2023
