Celery integration for django-tenant-schemas
Project description
tenant-schemas-celery
=====================
Usage:
* Define a celery app using given `CeleryApp` class.
```python
import os
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'app.settings')
from django.conf import settings
from tenant_schemas_celery.app import CeleryApp
app = CeleryApp()
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
```
This assumes a fresh Celery 3.1.13 application. For previous versions,
the key is to create a new `CeleryApp` instance that will be used to
access task decorator from.
* Replace your @task decorator with @app.task
```python
from django.db import connection
from myproject.celery import app
@app.task
def my_task():
print connection.schema_name
```
* Run celery worker (`myproject.celery` is where you've defined the `app`
variable)
```python
$ celery worker -A myproject.celery
```
* Post registered task. The schema name will get automatically added to the
task's arguments.
```python
from myproject.tasks import my_task
my_task.delay()
```
The `TenantTask` class transparently inserts current connection's schema into
the task's kwargs. The schema name is then popped from the task's kwargs in
`task_prerun` signal handler, and the connection's schema is changed
accordingly.
=====================
Usage:
* Define a celery app using given `CeleryApp` class.
```python
import os
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'app.settings')
from django.conf import settings
from tenant_schemas_celery.app import CeleryApp
app = CeleryApp()
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
```
This assumes a fresh Celery 3.1.13 application. For previous versions,
the key is to create a new `CeleryApp` instance that will be used to
access task decorator from.
* Replace your @task decorator with @app.task
```python
from django.db import connection
from myproject.celery import app
@app.task
def my_task():
print connection.schema_name
```
* Run celery worker (`myproject.celery` is where you've defined the `app`
variable)
```python
$ celery worker -A myproject.celery
```
* Post registered task. The schema name will get automatically added to the
task's arguments.
```python
from myproject.tasks import my_task
my_task.delay()
```
The `TenantTask` class transparently inserts current connection's schema into
the task's kwargs. The schema name is then popped from the task's kwargs in
`task_prerun` signal handler, and the connection's schema is changed
accordingly.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Close
Hashes for tenant-schemas-celery-0.1.0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 381977df92525363d4254d0033c2b4d1734abd674b3f922c0b78877872bed550 |
|
MD5 | 177247dd799c4a8215158cda53831056 |
|
BLAKE2b-256 | a48d934026185f6711672d9a9f5feb73f033360a966ec8883aff51ab2ba7d9cf |