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.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 042cf6ae8907d959e56a0580bd6a3386e655888bf38befd38ad446ee38e8df17 |
|
MD5 | fd09e2b142b74b0c101ab15e0f7ee866 |
|
BLAKE2b-256 | 89f949a84222ab4d7ca8fe7444a57f815f0528b09e7043ad1f2c2eaab249cf36 |