Wie überbrücken wir die Tests mit Resque mit Rspec Beispiele?

Ich habe eine Verwirrung bei der Umsetzung Resque parallel mit Rspec Beispiele.
Das folgende ist eine Klasse mit teuren Methode .generate(self)
class SomeClass
...
ChangeGenerator.generieren(selbst -)
...
Ende

Nach der Implementierung resque, die über Klasse folgt geändert und ergänzt eine ChangeRecorderJob Klasse.

class SomeClass
  ...
  Resque.enqueue(ChangeRecorderJob, self.id)
  ...
end

class ChangeRecorderJob
  @queue = :change_recorder_job

  def self.perform(noti_id)
    notification = Notification.find(noti_id)    
    ChangeGenerator.generate(notification)
  end
end

Funktioniert es perfekt. Aber ich habe 2 Bedenken.

Bevor Sie in meinem Beispiel-Skillung zu testen, die ganze Stapel von .generate(self) Methode. Aber jetzt, da ich darauf gedrängt, daß in Resque job, wie kann ich überbrücken meine Beispiele machen den gleichen test grün ohne Isolierung? Oder muss ich isolieren den test??

Und zu guter Letzt, wenn ich 10 Arbeitsplätze zu enque, habe ich, um 10 separate job-Klassen mit self.perform Methode?

InformationsquelleAutor Autodidact | 2011-02-28

resque rspec

34

Testen von asynchronen sowas ist immer schwierig. Was wir tun, ist:
- In unserer funktionalen tests stellen wir sicher, dass der job wird in die Warteschlange eingereiht. Mit Mokka oder etwas ähnliches mit einer Erwartung ist normalerweise ausreichend. Wenn Sie möchten, um einen test der redis-server verwenden, können Sie überprüfen Sie die korrekte Warteschlange wuchs und, dass der job params korrekt sind. Obwohl Sie sind Tests, Resque, selbst ein wenig an dieser Stelle.
- Arbeitsplätze sind isoliert getestet als unit-tests. Da Sie nur eine Methode der Klasse aufgerufen perform Ihre unit-tests sind ganz einfach. In Ihrem Fall würden Sie testen, dass ChangeRecorderJob.führen Sie das tut, was Sie wollen. Wir neigen dazu, zu testen, die Arbeitsplätze sind auf die entsprechende Warteschlange, dass die params der job gültig sind und den job tut, was wir wollen.
- Nun, um zu testen, alles zusammen ist der schwierige Teil. Ich habe dies auf zwei verschiedene Arten und jede hat vor-und Nachteile:
  - ~~Monkey-patch Resqueue.enqueue, um die Arbeit synchron~~ Als der resque 1.14.0, die Sie verwenden können Resque.inline = true in Ihrem Initialisierung statt der monkey-patching
  - Simulieren eines Arbeiters knallen einen job aus der Warteschlange und tatsächlich laufen in ein Gabel-Prozess
~~Ausführen der Aufgabe synchron ist bei weitem die einfachere der beiden. Sie hatte gerade die Last etwas wie das folgende in deiner spec_helper:~~

~~Modul Resque alias_method :enqueue_async, :enqueue def self.enqueue(klass, *args) klass.neu(0, *args).durchführen Ende Ende~~

Als der resque 1.14.0 können Sie nur setzen Resque.inline = true in Ihrem Initialisierung statt der monkey-patching. Wenn Sie stecken in einer älteren version von resque, der monkey-patch erforderlich ist.

Beachten Sie, dass Sie synchron laufen hier, Sie gehen, um die Kosten Ihrer lange Laufenden Auftrag. Vielleicht noch wichtiger ist, du gehst zu laufen in dem gleichen Prozess, also es ist nicht eine völlig genaue Darstellung von, wie Ihre Arbeit ausgeführt wird.

Ausführung des Auftrags, die in einem gegabelten Arbeiter, ähnlich wie resque würde, müssen Sie etwas tun, wie die folgenden:
```
def run_resque_job(job_class, job_args, opts={}) 
queue = opts [queue] || "test_queue" 

Resque::Job.erstellen(queue, job_class, *job_args) 
Arbeiter = Resque::Worker.neue(Warteschlange) 
Arbeiter.very_verbose = true, wenn opts[:verbose] 

wenn opts[:fork] 
# eine einzelne Aufgabe dann Herunterfahren 
def Arbeiter.done_working 
super 
shutdown 
Ende 
Arbeiter.Arbeit(0.01) 
sonst 
job = worker.reservieren 
Arbeiter.durchführen(Beruf) 
Ende 
Ende 
```
Es gibt eine leichte Verzögerung in das bekommen die Arbeitnehmer-pop-die Aufgabe aus der Warteschlange. Und natürlich werden Sie brauchen, um einen test der redis-server ausgeführt, so dass der Arbeiter hat eine Warteschlange, um pop-off.

Ich bin sicher, andere Leute kommen mit cleveren Arten der Prüfung resque Arbeitsplätze. Diese sind, was die gearbeitet haben für mich.
- Ich werde versuchen, diese Möglichkeiten und sehen es funktioniert für mich.
- Die Resque.inline = true ist eine clevere Lösung, aber wie gesagt kann Dinge machen träge, und den ich getroffen habe, Fällen in einige schlampig geschriebenen code, wo laufen Sie synchron hatte andere Ergebnisse als asynchron läuft. Es wäre cool, wenn Resque hatte eine test-helper, wo Sie tun könnte, rufe wie Resque.last_job, Resque.process!, und Resque.clear!.
InformationsquelleAutor nirvdrum

Verwenden resque_spec für unit-Tests.

describe "#recalculate" do
  before do
    ResqueSpec.reset!
  end

  it "adds person.calculate to the Person queue" do
    person.recalculate
    Person.should have_queued(person.id, :calculate).in(:people)
  end
end

Sowie für Ihre integration tests:

describe "#score!" do
  before do
    ResqueSpec.reset!
  end

  it "increases the score" do
    with_resque do
      game.score!
    end
    game.score.should == 10
  end
end

InformationsquelleAutor Les Hill

1

Müssen Sie tun, zwei verschiedene tests. Eine für enquing, um sicherzustellen, dass die jobs werden in die Warteschlange eingereiht in die Resque-Warteschlangen und die zweite für die Herstellung sicher, dass die Aufträge in der Warteschlange bei der Abholung durch den Arbeitnehmer durchgeführt werden, um Ihre Anforderungen.

Nein, Sie brauchen nicht zu schreiben 10 verschiedene Methoden führen. Beim ausführen von Resque Arbeiter, dann Holen Sie sich die jobs aus der queue und blind zu nennen .durchführen Methode auf Ihren job. So, Ihr job ist zu erwarten, dass die perform-Methode.
- Über das mehrfache ausführen-Methode, ich denke, ich konnte nicht deutlich machen. Können sagen, ich habe 3 Arbeitsplätze-Klasse mit Einzel - .perform - Methode in jedem. Diese 3 stellen sind für das gleiche Modell. Also statt zu schreiben 3 separate job-Klasse, wie Sie schreiben, diese 3 .perform in einem einzigen job Klasse?
- Die perform Methode nimmt varargs. Man könnte hinzufügen, eine Diskriminator-Wert, wenn Sie wollte und dann Ihr Einzel perform konnte nur Versand an egal welche Methode bietet die Funktionalität, die Sie benötigen.
- Vielen Dank für die Aufhellung mich.
InformationsquelleAutor Pratik Khadloya

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.