Jak wysłać odpowiedź, ale kontynuować realizację w Sinatrze?

Question

Robię małą aplikację Sinatra. Wykonuje kilka wywołań Redis, zwraca dane, a następnie wykonuje ostateczne wywołanie Redis, aby zapisać "statystyki".

Do tej pory, jeśli chcę zakończyć żądania wcześnie (oparte na wejściu), uważam, że można używać halt:

# code code 
halt send_blank if is_blocked? SETTINGS, host 
# code code 

Na samym końcu chcę mieć coś takiego:

response.body = JSON.generate(outgoing) 
# update user 
STATISTICS.hset('u:' + userID, 'data', JSON.generate({'ip' => request.ip, 'time' => Time.now.to_f.to_s})) 

Czy można wysłać odpowiedź, A następnie zrobić 5 ms redis, aby klient nie musiał czekać? Niezależnie od tego, gdzie i w jaki sposób ustawiam ostateczne wywołanie statystyki, opóźnia wysłanie odpowiedzi o kilka ms - nie może oszukać sinatry.

Można to łatwo wykonać w węźle, ale wystarczy napisać, co chcę zrobić, a zostanie ono uruchomione po wysłaniu odpowiedzi; o ile rozumiem, kod tutaj zablokuje wykonanie na około 5 ms przed cofnięciem odpowiedzi.

Próbowałem używać po .. do filtrów, a one działałyby dobrze oprócz tego, że nie można przekazać im niczego poza danymi w response.body - co oznacza, że ​​nie można przekazać do filtra niczego, co nie jest ". Zostanie wypuszczony! Można uniknąć tego problemu, przypisując zmiennej wartość poza zakresem postu ("/"), jednak przy ponad 100 żądaniach na sekundę, mam nadzieję, że możesz zobaczyć, w jaki sposób zamiana danych poprzez "globale" może stać się ogromnym problemem .

Wydaje się, że jest to coś naprawdę prostego, ale nie mogę znaleźć nic lepszego niż po. .. zrobić filtry w dokumentach.

Czy mogę utworzyć wątek lub coś, co sprawi, że proces redis.hset() nie będzie blokował, czy to zadziała? Wygląda na to, że hakujesz to hardcore.

Dzięki!

Answer 1

Rozwinięcie zapisu redis powinno działać.

coś takiego:

response.body = JSON.generate(outgoing) 
fork do 
    # update user 
    redis = Redis.new(:host => "your_host_name", :port => your_port_number) 
    redis.hset('u:' + userID, 'data', JSON.generate({'ip' => request.ip, 'time' => Time.now.to_f.to_s})) 
end