Octobot - A Low-Latency, Highly Parallel Distributed Task Queue Worker

http://octobot.taco.cat

by cscotta • 16 years ago

105 35 16 years ago

octobot.taco.cat

gmcquillan• 16 years ago

Fascinating. The thing I find interesting about this service is that it seems to work seamlessly with multiple queue backends. That would have been really useful at my company, where we completely swapped out our queue server infrastructure. Nice work!

jnoller• 16 years ago

Interesting; I'm looking forward to comparing/contrasting this with my current favorite - Celery (http://celeryproject.org/) which supports a variety of backends.

evgen2• 16 years ago

The throughput numbers on the chart would have seemed a bit more valid if the task had not included stuffing the result into a protobuf given the notoriously slow performance of the standard python protobuf implementation that would have been used by Celery and PyInvoke. If they wanted to impress, or at least be honest, the data would have stayed in JSON the whole way through the stack and the worker task would have been a simple string manipulation of something similar.

cscotta2• 16 years ago

Hi there,

The task benchmarked was from a component of our messaging stack at work that I'd ported. My intention was to offer an example of the end-to-end performance of a real-world task that someone might be writing, rather than a sample task that's not much more than a no-op. I'd suggest that this particular one is real-world as it's straight out of one of our applications. I've no intention of trying to be dishonest here - just offering the measurements of my (and our) internal evaluation of the tool for our needs.

While I can't provide the source of the task, I can offer the quick-and-dirty source of the quick little "PyInvoker" I'd whipped up (sorry - didn't realize there was something called PyInvoke at the time). It just takes a message, unpacks the JSON, and uses getattr to call the appropriate task. Nothing fancy like e-mail error notifications, retries, and the like: https://gist.github.com/18a30689832569d67861

Anyhow, always and absolutely take any claims regarding the performance of a tool with a massive grain of salt, and try them for yourself to see if they suit your needs. Octobot's not designed to replace background processing in most applications as tools like Celery and DelayedJob (both of which I use myself) are great, a bit easier to write for, and a bit simpler to get up and running, depending on the application and language being used.

There's no intention to have slighted anyone or any other project here. I'm stoked that a lot of tools exist in this space. I just hadn't seen one on the JVM that offered this level of simplicity and parallelism with a bit of restraint when it comes to feature creep. But if you have an application that demands high throughput / low latency execution of tasks, this might be worth evaluating.

evgen2• 16 years ago

No problem. I did not want to suggest that you were fudging numbers or anything, but it just appeared to be a strange selection of parameters for a comparison chart (and to be honest, whenever I see a comparison chart that shows X outperforming Y by more than 10X I tend to take a closer look at the details of what is being compared...)

As to the task selection, I do not think showing a "real-world" task help here, since we all have different tasks to be performed out in the real world. I want to know what overhead a particular piece of infrastructure adds, so something as close as possible to a no-op is a useful data point.

asksol2• 16 years ago

I'm interested in seing the code/config used to benchark Celery. The default settings are not at all optimized for processing lots of small jobs, and you could easily tweak it to get a 100x speed up for that use case, e.g.:

   CELERYD_PREFETCH_MULTIPLIER = 0
   CELERY_DISABLE_RATE_LIMITS = True

Also, channels are not re-used unless you explicitly pass the Publisher, so e.g.

   publisher = task.get_publisher()
   for i in xrange(1000):
       task.apply_async(args=(i, ), publisher=publisher)
   publisher.close()

is known to be a massive speed-up for sending tasks in batch (it seems the creation of channels is very expensive in pyamqplib).

dataguy• 16 years ago

Sounds like a nice tool. Will definitely give it a try for high work-load statistical data processing.

moe• 16 years ago

Looks interesting at a glance.

But guys, seriously, make your docs available in HTML format. PDF-only docs are out of fashion since the 90s.

Sukotto• 16 years ago

This is a good case-study of what to do when building a home page for your project.

1) State what your project is about using language that a reasonably savvy (technology-wise) user can understand, even if unfamiliar with the problem domain. (this site would be better if they linked on "message queue" for those people that don't know what that is.)

2) Eye-catching call to action icons

3) Brief list of most important features

4) Brief high-level view

5) Brief low-level view

6) Some clean and minimalist stats on why you might want to use it

7) Easy to understand links to more info.

I don't know if I will ever need this product... but I'm bookmarking it anyway as an outstanding example of how to introduce people to it. (Except for the swear word. The word "Fucking" is really out of place)

Nice job guys.

superjared3• 16 years ago

"Portland Fucking Oregon" is definitely a PDX thing. "We're too cool to not swear" or something. I dig it, but then I live here.

JoachimSchipper• 16 years ago

I thought their list of adjectives was too long; half of them boiled down to "performant", too, which is not too useful (of course you're trying to be performant; calling out throughput or latency specifically is useful because it helps people evaluate your work for their needs, but having both gives very little information...)

waratuman• 16 years ago

Interesting, but won't ever use. It also seems that it is just wrapping typical queueing systems, which I would use anyways because this only supports the JVM.

superjared3• 16 years ago

This is a worker system that uses queues, not a queue unto itself.

DEinspanjer2• 16 years ago

Very interesting. We're currently working on a quick project to test integrating Hazelcast into a distributed server to use as a queue. Did you look at it by any chance? Curious if it was missing something that you needed.

cnlwsu2• 16 years ago

From my personal experience with these, Hazelcast seems to be better suited for something like a single worker queue... We had issues when we had thousands of distributed queues on different systems. We ended up going with Terracotta (which handles this well if you work through the lock contention).

This project sounds promising for that kind of application but wont know until I try it out.

DEinspanjer2• 16 years ago

Sorry for my confusion, so is the problem you experienced one of having thousands of queues that a small number of clients pulled from, or thousands of workers that worked off of a small number of queues?

In our case, we want to be having a very small number of queues that have a high rate of i/o with dozens of reader clients and writer clients.

chrisduesing• 16 years ago

Am I the only one who got really excited upon seeing the domain was octobot.taco.cat, and then very confused when going to www.taco.cat? It seems to be an art gallery in Spanish or something...

I realize this is not germane to the topic, but .cat!? What other really interesting tld's exist that I have never heard about?

listic2• 16 years ago

It really surprised me that they assigned three-letter TLD for Catalan, whereas all other countries have two-letter TLD's.

It happens to be not a country code (http://en.wikipedia.org/wiki/List_of_Internet_top-level_doma...), but the generic TLD, alongside the likes of .com and .org, "for Web sites in the Catalan language or related to Catalan culture", the only one of this kind in this category. Go figure.

Semiapies• 16 years ago

It's for the Catalan language:

http://en.wikipedia.org/wiki/.cat - http://en.wikipedia.org/wiki/Catalan_language

I think I need to take a look at the TLDs available, lately, because I know a lot have slipped under my radar.

there2• 16 years ago

did anyone else have to take a second look at that domain name?

rubashov• 16 years ago

tako is japanese for octopus...

there2• 16 years ago

i was more interested in the .cat tld

johngalt2• 16 years ago

Sorry to be the slow one here... What is a Distributed Task Queue Worker? What problem does it solve?

listic2• 16 years ago

Yup. I'm just wrapping my head around the things like RabbitMQ and Redis and I think I understand what those are for. But can someone explain straight: in which case should I want to use this Octobot?

superjared3• 16 years ago

Octobot (like Celery, Resque, et al) is a worker, meaning that it takes messages from a queue, such as Rabbit or Redis, and processes that message based on a task that you write. Imagine Octobot being used to create thumbnails for Flickr--a job that should be done asynchronously.

metabrew• 16 years ago

I like that it has the capability to be an email queue build in, by supporting SMTP/SSL. Worth installing just for that, since that's the first thing lots of websites want a message queue for.

swah• 16 years ago

Surprised to see it wasn't written in Scala, since Scala shows up before in their list of supported languages and Scala code example also comes first.

Octobot - A Low-Latency, Highly Parallel Distributed Task Queue Worker

Related Stories