metodi multipli per lavoratore sidekiq

Question

Non capisco.

Per documentazione Sidekiq, ogni operatore (il mio è chiamato FeedWorker) può contenere solo un metodo chiamato perform. Bene, cosa succede se voglio eseguire più metodi attraverso lo stesso operatore?

Per esempio, il mio FeedWorker (avete indovinato, si elabora un feed attività) dovrebbero eseguire i seguenti 3 metodi:

announce_foo 
announce_bar 
invite_to_foo 

non credo che questo è un'aspettativa irragionevole. Sono sicuro che altri lo abbiano considerato. Non sono un genio, ma so che non sto aprendo nuovi orizzonti nelle aspettative qui. Eppure non è chiaro come si farebbe questo.

In questo momento, sembra che devo codice in questo modo:

def perform(id, TYPE) 
    if TYPE == BAR 
    Bar.find(id) and_announce_bar 
    else 
    Foo.find(id) and_announce_foo 
    end 
end 

codice noioso e brutto. Ci deve essere meglio là fuori. Qualsiasi aiuto apprezzato!

Answer 1

perform metodo è il punto di ingresso del tuo Worker. Al suo interno è possibile creare tutti i metodi di istanza che si desidera, per organizzare il codice nel modo più adatto alle proprie esigenze. È comunque buona pratica mantenere il codice del lavoro il più snello possibile. Chiamare altri oggetti dall'interno di esso, ad esempio, è un modo per ottenerlo. Scoprirai che il tuo codice sarà più facile da testare.

Answer 2

ho avuto la stessa domanda per un po 'e ora hanno una soluzione piuttosto semplice: utilizzare il metodo di estensione in ritardo su qualsiasi classe, come spiegato in docs, ad es:

# Usage: EmailWorker.delay.do_something 

class EmailWorker 
    class << self 
    def send_this(attrs) 
     MyMailer.some_action(attrs).deliver 
    end 

    def send_that(attrs) 
     MyMailer.another_action(attrs).deliver 
    end 
    end 
end 

Ogni classe può essere ritardato, in modo da non è necessario includere Sidekiq :: Worker se non si utilizzerà il metodo perform_async.

Il problema che ho riscontrato è che le opzioni per lavoratore non verranno utilizzate a meno che non si passi al metodo perform_async.