Inserting Celery tasks directly into Redis

Question

I have an Erlang system. I want this system to be able to trigger Celery tasks on another, Python-based system. They share the same host, and Celery is using Redis as its broker.

Is it possible to insert tasks for Celery directly into Redis (in my case, from Erlang), instead of using a Celery API?

Answer 1

Yes, you can insert tasks directly into redis or whatever backend you are using with celery.

You'll have to match the celery serialization format (which is in JSON by default) and figure out which keys it is inserting to. The key structure used isn't clearly documented, but this part of the source code is a good place to start.

You can also use the redis monitor command to watch which keys celery uses in real time.