Shoryuken

Shoryuken est un processeur de messages basé sur les threads pour AWS SQS. AppSignal instrumente automatiquement Shoryuken lorsque la gem Shoryuken est détectée au démarrage. Aucune installation manuelle n’est requise si Shoryuken fait partie d’une application Rails. Si vous utilisez une application Shoryuken autonome, consultez notre guide d’intégration.

Surveillance des performances

Chronologie des événements

Les jobs Shoryuken apparaissent dans la chronologie des événements des actions de performance de votre application sous forme d’événements perform_job.shoryuken.

Regroupement d’incidents

AppSignal détecte les noms de jobs à partir du nom de classe du worker Shoryuken, suffixé par le nom de la méthode perform, ce qui donne quelque chose comme : MyWorker#perform. AppSignal regroupe les jobs par ce nom pour les incidents de performance et les notifications.

Instrumentation de mise en file d’attente

La mise en file d’attente d’un job Shoryuken enregistre un événement enqueue.shoryuken, intitulé d’après le job mis en file d’attente. AppSignal enregistre les événements de mise en file d’attente dans la chronologie des événements de la transaction active, par exemple lorsque vous mettez en file d’attente un job depuis une requête web ou depuis un autre job. Il ne les enregistre que lorsqu’une transaction est active, donc mettre en file d’attente un job en dehors d’une transaction n’enregistre rien. Pour arrêter d’enregistrer les événements de mise en file d’attente pour toutes les intégrations de jobs en arrière-plan, définissez l’option de configuration enable_job_enqueue_instrumentation sur false. Cela n’affecte pas l’instrumentation des jobs eux-mêmes.

Prise en charge des lots

Si une application utilise un worker avec l’option :batch => true, ce worker traite plusieurs messages dans le même tick. Cela nécessite la version 2.11.3 ou supérieure de la gem Ruby, qui ajoute la prise en charge de l’option 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

Exemple d’application

Nous avons un exemple d’application pour une application Shoryuken autonome disponible dans notre dépôt d’exemples sur GitHub.

Sequel

Sidekiq

⌘I

AppSignal pour Ruby

AppSignal pour Elixir

AppSignal pour Node.js

AppSignal pour front-end

AppSignal pour Python

AppSignal pour Go

AppSignal pour Java

AppSignal pour PHP

OpenTelemetry

Wrap

Collector

Agent autonome

Surveillance des performances

Chronologie des événements

Regroupement d’incidents

Instrumentation de mise en file d’attente

Prise en charge des lots

Exemple d’application

​Surveillance des performances

​Chronologie des événements

​Regroupement d’incidents

​Instrumentation de mise en file d’attente

​Prise en charge des lots

​Exemple d’application

Surveillance des performances

Chronologie des événements

Regroupement d’incidents

Instrumentation de mise en file d’attente

Prise en charge des lots

Exemple d’application