español - sinatra ruby github

Transmisión de datos desde la aplicación Sinatra/Rack

Question

Estoy tratando de transmitir datos de texto (XML / JSON) desde una aplicación Ruby (1.9.1p378) Sinatra (1.0) Rack (1.2.1). Las soluciones sugeridas (p. Ej. ¿Existe una forma de descargar html al cable en Sinatra ) no parecen funcionar? El servidor solo bloquea cuando cedo elementos de una corriente infinita (p. Ej., De %w(foo bar).cycle ). Intenté webrick y thin como servidores.

¿Alguna sugerencia sobre cómo hacer esto? ¿Debo usar http://sinatra.rubyforge.org/api/classes/Sinatra/Streaming.html y, de ser así, cómo lo usaría en mi aplicación?

Answer 1

A partir de Sinatra 1.3, también podría usar la nueva API de transmisión:

get ''/evented'' do
stream(:keep_open) do |out|
EventMachine::PeriodicTimer.new(1) { out << "#{Time.now}/n" }
end
end

Answer 2

Como mencionó Colin, Goliath puede transmitir datos de respuesta, así como entrantes (grandes archivos subidos). Hay un ejemplo en el repositorio para transmitir datos al cliente: https://github.com/postrank-labs/goliath/blob/master/examples/stream.rb

En lugar de un temporizador, puede conectar fácilmente cualquier otro flujo de datos para enviar datos al cliente. Por ejemplo, puede conectar una cola AMQP, o cualquier otra cola de mensajes directamente a Goliath y dejar que actúe como una interfaz HTTP para esos datos.

Answer 3

Definitivamente deberías echarle un vistazo al servidor web Goliath capaz de instalar en rack. Es compatible con la transmisión fuera de la caja. Lo estoy usando para un api de streaming de estilo firehose.

Goliath es tanto un servidor de aplicaciones como un marco ligero diseñado para cumplir los siguientes objetivos: procesamiento completamente asíncrono, soporte de middleware, configuración simple, alto rendimiento y, posiblemente, el código más legible y mantenible.

Answer 4

Ni Webrick ni Thin soportan la transmisión de esa manera. Podrías probar Mestizo o Unicornio. Si desea utilizar Thin o Rainbows !, debe conectarse al bucle de eventos para lograr la transmisión:

require ''sinatra''
class Stream
include EventMachine::Deferrable
def initialize
@counter = 0
end
def each(&block)
if @counter > 10
succeed
else
EM.next_tick do
yield counter
each(&block)
end
end
end
end
get ''/'' do
Stream.new
end

Recientemente escribí una implementación de EventSource de esa manera:

require ''sinatra''
class EventStream
include EventMachine::Deferrable
def each
count = 0
timer = EventMachine::PeriodicTimer.new(1) do
yield "data: #{count += 1}/n/n"
end
errback { timer.cancel }
end
end
get ''/'' do
EventMachine.next_tick do
request.env[''async.callback''].call [
200, {''Content-Type'' => ''text/event-stream''},
EventStream.new ]
end
[-1, {}, []]
end

Si desea utilizar Webrick para transmisión: here hay un parche.