Skip to main content

A Publish and Subscribe library for Celery

Project description

celery-pubsub 0.1.8 Code Climate Test Coverage Issue Count

Publish and Subscribe with Celery

Basic usage:

import celery
import celery_pubsub

def my_task_1(*args, **kwargs):
    return "task 1 done"

def my_task_2(*args, **kwargs):
    return "task 2 done"

# First, let's subscribe
celery_pubsub.subscribe('some.topic', my_task_1)
celery_pubsub.subscribe('some.topic', my_task_2)

# Now, let's publish something
res = celery_pubsub.publish('some.topic', data='something', value=42)

# We can get the results if we want to (and if the tasks returned something)
# But in pub/sub, usually, there's no result.

# This will get nowhere, as no task subscribed to this topic
res = celery_pubsub.publish('nowhere', data='something else', value=23)

Advanced usage:

Wildcards can be used in topic names:

  • * matches any one group
    • some.*.test will match some.awesome.test, some.random.test but not, elsewhere or here.some.up.test
    • some.* will match some.test and some.thing but it won’t match some or some.testy.test
  • # matches any number of groups
    • some.#.test will match some.awesome.test, some.random.test, but not elsewhere or here.some.up.test
    • some.# will match anything that starts with some., such as some.very.specific.topic.indeed
    • # will match anything
# Let's subscribe
celery_pubsub.subscribe('some.*', my_task_1)
celery_pubsub.subscribe('some.*.test', my_task_2)
celery_pubsub.subscribe('some.#', my_task_3)
celery_pubsub.subscribe('#', my_task_4)
celery_pubsub.subscribe('some.beep', my_task_5)
# it's okay to have more than one task on the same topic
celery_pubsub.subscribe('some.beep', my_task_6)

# Let's publish
celery_pubsub.publish('nowhere', 4)               # task 4 only
celery_pubsub.publish('some', 8)                  # task 4 only
celery_pubsub.publish('some.thing', 15)           # tasks 1, 3 and 4
celery_pubsub.publish('some.true.test', 16)       # tasks 2, 3 and 4
celery_pubsub.publish('some.beep', 23)            # tasks 1, 3, 4, 5 and 6
celery_pubsub.publish('some.very.good.test', 42)  # tasks 3 and 4

# And if you want to publish synchronously:
celery_pubsub.publish_now('some.very.good.test', 42)  # tasks 3 and 4

# You can unsubscribe too
celery_pubsub.unsubscribe('#', my_task_4)

# Now, task 4 will not be called anymore
celery_pubsub.publish('some.very.good.test', 42)  # task 3 only


  • 0.1.8
    • Fixup for broken pip install celery_pubsub==0.1.7
  • 0.1.7
    • PyPI long description fixed
    • Removed and fixed README.rst
    • Added command python test to run unit tests with coverage
    • pypy support
  • 0.1.5
    • Python 3 support
  • 0.1.1
    • Added README
    • Refined setup
    • No need to access celery_pubsub.pubsub anymore. Direct access in celery_pubsub.
    • Tests moved out of package
    • Added Travis for CI
  • 0.1
    • Initial version

Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Filename, size & hash SHA256 hash help File type Python version Upload date
celery-pubsub-0.1.8.tar.gz (4.8 kB) Copy SHA256 hash SHA256 Source None Nov 2, 2017

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page