Shoryuken

Shoryuken é um processador de mensagens baseado em threads para o AWS SQS. O AppSignal instrumenta o Shoryuken automaticamente quando a gem Shoryuken é detectada na inicialização. Nenhuma instalação manual é necessária se o Shoryuken faz parte de um app Rails. Se você está usando um app Shoryuken autônomo, consulte nosso guia de integração.

Performance monitoring

Event timeline

Jobs do Shoryuken aparecem na event timeline das actions de performance da sua aplicação como events perform_job.shoryuken.

Incident grouping

O AppSignal detecta os nomes dos jobs a partir do nome da classe do worker Shoryuken, sufixado com o nome do método perform, resultando em algo como MyWorker#perform. O AppSignal agrupa jobs por esse nome para performance incidents e notificações.

Enqueue instrumentation

Enfileirar um job do Shoryuken registra um event enqueue.shoryuken, com o título baseado no job sendo enfileirado. O AppSignal registra events de enqueue na event timeline da transaction ativa, por exemplo, quando você enfileira um job a partir de uma requisição web ou de dentro de outro job. Ele só registra esses events quando uma transaction está ativa, então enfileirar um job fora de uma transaction não registra nada. Para parar de registrar events de enqueue em todas as integrações de background job, defina a opção de configuração enable_job_enqueue_instrumentation como false. Isso não afeta a instrumentação dos jobs em si.

Suporte a batch

Se um app usa um worker com a opção :batch => true, esse worker processa várias mensagens no mesmo tick. Isso requer a gem Ruby 2.11.3 ou superior, que adiciona suporte à opção batch.

# my_worker.rb
class MyWorker
  include Shoryuken::Worker

  shoryuken_options :queue => "batched", :batch => true

  def perform(sqs_msg, body)
    # Do stuff
    puts "Performing BatchedWorker job: #{body}"
    sleep 1
  end
end

Aplicação de exemplo

Temos uma aplicação de exemplo para um app Shoryuken autônomo disponível no nosso repositório de examples no GitHub.

Sequel

Sidekiq

⌘I

AppSignal para Ruby

AppSignal para Elixir

AppSignal para Node.js

AppSignal para front-end

AppSignal para Python

AppSignal para Go

AppSignal para Java

AppSignal para PHP

OpenTelemetry

Wrap

Collector

Agente standalone

Performance monitoring

Event timeline

Incident grouping

Enqueue instrumentation

Suporte a batch

Aplicação de exemplo

​Performance monitoring

​Event timeline

​Incident grouping

​Enqueue instrumentation

​Suporte a batch

​Aplicação de exemplo

Performance monitoring

Event timeline

Incident grouping

Enqueue instrumentation

Suporte a batch

Aplicação de exemplo