Memorizzazione di un ID attività per ogni attività di sedano nella banca dati

Question

Uso il sedano con MySQL. Voglio memorizzare l'ID attività come un numero intero semplice in un database o in una variabile di sedano task. Come lo posso fare?

Answer 1

Perché non creare un modello di attività di sedano e salvare un ID di attività di tipo sedano su tale modello?

class CeleryModel(models.Model): 
    celery_task_id = models.CharField(max_length = 50, unique=True) 

Poi:

def some_celery_task(): 
    result = celery_task.delay() 
    celery_task = CeleryModel(celery_task_id = result.id) 
    celery_task.save() # added save line 

tuo valore intero sarebbe allora: celery_task.id per corrispondere con l'attuale, celery_task_id unico.

UPDATE: un altro modo ...

First python manage.py inspectdb > inspectdb.py. All'interno di tale file troverai:

class CeleryTaskmeta(models.Model): 
    id = models.IntegerField(primary_key=True) 
    task_id = models.CharField(max_length=765, unique=True) 
    status = models.CharField(max_length=150) 
    result = models.TextField(blank=True) 
    date_done = models.DateTimeField() 
    traceback = models.TextField(blank=True) 
    hidden = models.IntegerField() 
    meta = models.TextField(blank=True) 
    class Meta: 
     db_table = u'celery_taskmeta' 

Avanti, python manage.py startapp celery_model. Metti questo file nel file models.py. Io uso il sud, quindi il mio ultimo passaggio sarebbe python manage.py convert_app celery_model. Tuttavia, non è necessario. Ora hai accesso al livello django a questo dato sedimentario, e puoi leggere la chiave primaria per ogni attività come valore intero. Per esempio

>>> ct = CeleryTaskmeta.objects.get(id=1) 
>>> for k,v in ct.__dict__.items(): print k,v 
... 
status SUCCESS 
task_id 2fa95f24-7640-434c-9fef-0732ac1d23c7 
date_done 2013-02-17 19:22:56+00:00 
traceback None 
_state <django.db.models.base.ModelState object at 0x10263fa90> 
meta eJxrYKotZAzlSM7IzEkpSs0rZIotZC7WAwBREgb9 
result gAJLBC4= 
hidden 0 
id 1 

Qualcuno intelligente saprebbe come rendere il vostro CeleryTaskmeta un modello di sola lettura, perché non credo che si vorrebbe manomettere il datatable.

UPDATE: per l'ultima parte della tua domanda:

>>> from celerytest.tasks import add 
>>> result = add.delay() 
>>> result.int_id = 1 
>>> for k,v in result.__dict__.items(): print k,v 
... 
parent None 
app <Celery default:0x10264df10> 
task_name celerytest.tasks.add 
int_id 1 
id 01503afd-d196-47af-8e10-e7dc06603cfc 
backend <djcelery.backends.database.DatabaseBackend object at 0x1026842d0> 

Answer 2

Per ottenere l'ID attività sedano quando viene avviato il compito faccio la seguente:

process_task = my_task.apply_async(args=[args]) 
task_id = process_task.task_id 

dove my_task è un metodo all'interno tasks.py