¿Cómo enviar una respuesta pero continuar la ejecución en Sinatra?

Question

Estoy haciendo una pequeña aplicación de sinatra. Realiza un par de llamadas a Redis, devuelve los datos y luego realiza una llamada final a Redis para guardar las "estadísticas".

Hasta ahora si quiero cancelar la solicitud temprana (basado en la entrada), encontré que puedo usar halt:

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

Al final quiero tener algo como esto:

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

¿Es posible enviar la respuesta y ENTONCES hacer la escritura de redis 5ms, para que el cliente no tenga que esperar? No importa dónde o cómo coloque las estadísticas finales redis call, retrasa el envío de la respuesta por algunos ms - no se puede engañar a sinatra.

Esto se puede realizar fácilmente en Nodo, pero simplemente escribiendo lo que quiero hacer y se disparará después de que se haya enviado la respuesta; Por lo que yo sé, el código aquí bloqueará la ejecución durante aproximadamente 5 ms antes de disparar una respuesta.

He intentado utilizar después de ... hacer filtros, y funcionarían bien, excepto que no se les puede pasar nada más que los datos en response.body, lo que significa que no se puede pasar al filtro nada que no sea va a salir! Es posible evitar este problema asignando variables fuera del alcance de la publicación ("/"); sin embargo, con más de 100 solicitudes por segundo, espero que pueda ver cómo el intercambio de datos a través de "globales" puede convertirse en un gran problema .

Parece algo realmente simple pero no puedo encontrar nada mejor que después ... hacer los filtros en los documentos.

¿Puedo crear un hilo o algo para que el proceso redis.hset() no sea bloqueante, funcionará? Parece que lo pirateó duro.

Gracias!

Answer 1

Bifurcar la escritura redis debería funcionar.

Algo como esto:

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