Wednesday, January 28, 2009

Getting Async With Sinatra And Passenger Using spork


Everyone wants it all. In the case of upload processing, this means we want both the convenience of Sinatra coding, plus the performance that a nice process/threading model gives us. Go off and do some work I just assigned you, and don't make me wait around to see you do it.

If you are using Passenger, it already is buffering your uploads, and not calling your Sinatra application until the upload is complete. That saves system resources for more important things, like even more uploads. Pretty nice.

But a lot of work often has to take place after the upload is completed. A common example these days would be a video transcoding or image processing server. Once your user has uploaded their file, it would be considerate to let them go off and do something else. Sites like YouTube and Flickr have been doing exactly this for some time.

For certain highly transactional system, a solid message queue would be essential. But more humble needs, like an upload/transcoding/image thumbnail server, does not really need all of those extra moving parts.

Thanks to the power of the underlying Ruby language itself, it is very simple to fork off blocks of code into a separate process. Combining this with Passenger's already pretty robust process handling, and you get a pretty well performing solution with not much coding effort.

But wait... it does not work?! Sure enough, there are issues in the underlying interaction between Passenger and Rack, that you must address, or your long-running code will be just that, long-running, making the user sit there and wait for it to complete before Passenger allows Sinatra to return a response.

Enter spork... a blatant ripoff of both the spoon and the fork... I mean of the Spawn plugin for Rails, except with no actual Rails stuff in it, of course. spork handles the monkeypatching required to get things working the way they should be, and also lets you run under thin with no code changes should you so wish, like when running in development mode locally.

Anyhow, it may not be a glamorous implement, but it is a useful one. Have a look at spork if you are using Sinatra on Passenger, and you want to get all asynchronous on your users.

2 comments:

Vais said...

Thank you, Ron, but there are some serious problems with this approach, primarily because the entire process is forked, RAM footprint and all.

Example: I have a 1/4GB Joyent Accelerator, and my sinatra/thin process is around 20MB. Let's say the forked code takes 30 seconds to complete (why not?). Exercise for the reader: how many concurrent requests to this sinatra route will it take to start getting this:

Errno::ENOMEM - Not enough space - fork(2)

spork.rb:40:in `fork'
spork.rb:40:in `spork'
app.rb:37:in `GET /spork'
/opt/local/bin/thin:19:in `load'
/opt/local/bin/thin:19

Spoiler/Answer: Not nearly enough :)

Vais

Ron Evans said...

I use Passenger to run my application, which has some different Copy-On-Write behavior than Ruby does normally on its own. I have not tried to run under Thin, and given the standard GC behavior of normal Ruby, that does not surprise me.