Описание тега shoryuken

Обработчик сообщений на основе потоков AWS SQS для Ruby https://github.com/phstc/shoryuken
1 ответ

Настройка Shoryuken, Active Job и Amazon SQS в проекте Rails

Как относительный новичок в AWS, было немного сложно заставить работать камень Shoryuken (с Active Job и Active Record) на основе документации по настройке. Промежуточное программное обеспечение: я не был уверен, является ли промежуточное программно…
2 ответа

Конкретная конфигурация шорюкена

Я использую камень Shoryuken, запустив bundle exec shoryuken -R -C config/shoryuken.yml а шорюкен.имль есть concurrency: 25 delay: 0 queues: - [development_high, 30] - [development_mid, 6] - [development_low, 2] Это отлично работает. Тем не менее, я…
08 фев '17 в 21:29
2 ответа

Маркер безопасности, включенный в запрос, недействителен. AWS::SQS:: Ошибки::InvalidClientTokenId

Когда я пытаюсь начать shoryuken, я получаю эту ошибку Маркер безопасности, включенный в запрос, недействителен. (AWS::SQS:: Ошибки::InvalidClientTokenId). Даже это работало для меня ранее. Сообщение добавлено в очередь, но работник не может получит…
2 ответа

Не может запустить рельсы драгоценного камня в производственной среде, которая читает из SQS

Gem shoryuken является фоновым рабочим для приложений rails, который читает из aws SQS. Я могу управлять рабочим шорюкен в моем регионе, и он работает нормально. Когда я запускаю его в производственной среде в AWS, он не работает. Как вы запускаете …
0 ответов

Вручную повторить неудачную работу sqs с shoryuken

В настоящее время я создаю панель администратора для мониторинга наших очередей SQS, вдохновленную этим средним постом. Мне удалось все нормально работать с этим кодом в моем специальном ПО shoryuken: class DashboardMiddleware def call(worker_instan…
08 июн '18 в 15:17
1 ответ

Ошибка shoryuken в `validate_queues': указанные очереди

Я использую rails "Shoryuken" gem, но я получаю ошибки для проверки очередей в моей среде разработки, когда я запускаю rails server. Ниже приведена ошибка:- gems / shoryuken-2.0.11 / lib / shoryuken / environment_loader.rb: 172: в `validate_queues':…
1 ответ

SQS + Shoryuken: большое количество полученных в FIFO, несмотря на auto_delete=true

У меня есть очередь AWS SQS FIFO, настроенная для дедупликации сообщений на основе содержимого. Мое приложение rails использует рабочий Shoryuken для получения сообщений от SQS. Вот рабочий код: class MyJob include Shoryuken::Worker shoryuken_option…
12 дек '18 в 20:10
2 ответа

Как определить параллелизм (потоки) при использовании shoryuken для фоновых заданий?

В моем приложении Ruby on Rails я использую shoryouken для фоновой обработки. В моем приложении много очередей sqs (6-7). Одна из очередей имеет 2000-3000 заданий, и работнику требуется около 3 часов для обработки этих 2-3 тыс. Заданий с параллелизм…
1 ответ

Ошибка десериализации при обработке рабочих заданий

Я пытаюсь создать фоновые задания для почтовой программы, используя AWS работника, переопределив метод devise. def send_devise_notification(notification, *args) devise_mailer.send(notification, id, *args).deliver_later end Я помещаю почтовую програм…
1 ответ

Отправка сообщения на устройства через SQS

Я все еще изучаю SQS, я провел несколько успешных тестов с SQS и приложением Ruby с Shoryuken, которое собирает сообщения. Это отлично работает. Мы хотим установить 1000 IoT-устройств в домах людей. Эти устройства будут отправлять события на сервер,…
16 окт '18 в 08:42
1 ответ

Настройка задержек повтора с помощью Amazon SQS от Shoryuken (ruby)

Я перевожу сервис обработки фоновых заданий, созданный с помощью sidekiq, на shoryuken, основанный на Amazon SQS. С Sidekiq вы можете настроить шаблон повторов, используя sidekiq_retry_in: class WorkerWithCustomRetry include Sidekiq::Worker sidekiq_…
08 сен '15 в 15:14
1 ответ

Как получить статистику работы с Shoryuken?

Есть ли способ получить статистику работы от Shoryuken, аналогичную статистике Sidekiq, через API ( https://github.com/mperham/sidekiq/wiki/API)?
15 апр '19 в 00:44
0 ответов

Работник shoryuken продолжает повторять попытки с последним интервалом повтора бесконечное количество раз после сбоя

Я использовал shoryuken_options retry_intervals: [120, 240] согласно вики https://github.com/ruby-shoryuken/shoryuken/wiki/Worker-options#retry_intervals Но заметил, что после сбоя первая и вторая попытки повтора были такими ожидается, но после втор…
29 июн '21 в 17:29
0 ответов

Активное задание: как отправить электронное письмо после завершения вложенных заданий

Пример: у меня есть ImportJob , которое выполняет итерацию по страницам контактов и запускает ParserJob , который выполняет итерацию по контактам и запускает ProcessJob для каждого контакта. Я разделил эту работу, чтобы повысить производительность. …
2 ответа

Поддержание FIFO при переходе с Sidekiq на Shoryuken

В настоящее время мы выполняем обработку событий в порядке FIFO в нашем приложении Rails, используя очередь в Sidekiq. По ряду причин — стоимости и некоторых других преимуществ — мы переходим с Sidekiq на Shoryuken(с очередью SQS FIFO). В настоящее …
0 ответов

Шорюкен пытается повторно обработать сообщение SQS в полете.

В настоящее время у меня есть приложение rails 6, использующее Shoryuken (5.2.3) с SQS для асинхронной обработки и загрузки изображений, инициированных пользователем. Похоже, все работает так, как ожидалось, если учесть побочные эффекты задания (вкл…
0 ответов

Как Shoryuken Process может считывать учетные данные aws из профиля IAM

У нас есть настройка рабочего процесса shoryuken в приложении rails (ruby 2.6.6, rails > 5). это файл shoryuken.yml.erb :aws: :access_key_id: ? :secret_access_key: ? :region: <%= Settings.aws.region %> :concurrency: 10 :daemon: false :pidfi…
22 сен '22 в 13:05
0 ответов

Рабочий каталог для Shoryuken и Sidekiq

У меня есть приложение rails, в котором мы хотим использовать как sidekiq (очередь Redis), так и shoryuken (очередь SQS) для разных вариантов использования. Итак, теперь все рабочие sidekiq определены в app/workers. Чтобы отделить рабочие шорюкены, …
27 сен '22 в 11:24
0 ответов

Active::Джов и Сёрюкен действуют на SIGTERM

В моем приложении Rails у меня есть бегун Shoryuken в качестве бегуна в стеке Kubernetes. У меня есть какое-то длительное задание, и я хочу выполнить какое-то действие, когда рабочий модуль остановлен. Насколько я знаю, Kubernetes отправляет работни…
0 ответов

Получение упаковщика: не удалось загрузить команду: shoryuken (/usr/local/bundle/bin/shoryuken)

В журналах контроля качества появляется сообщение об ошибке ниже. Ниже приведена информация о моей настройке. Версия Ruby: Ruby 3.0.3p15 Версия Rails: Rails 7.0.3 Версия Bundler: Версия Bundler 2.3.6Shoryuken: версия Shoryuken 6 устанавливается во в…
12 июл '23 в 17:15