我使用芹菜MySQL
。我想将任务ID作为普通整数存储在数据库或芹菜变量task
中。我怎样才能做到这一点?在数据库中存储每个芹菜任务的任务ID
6
A
回答
12
为什么不创建芹菜任务模型,并将芹菜任务ID保存到该模型?
class CeleryModel(models.Model):
celery_task_id = models.CharField(max_length = 50, unique=True)
然后:然后
def some_celery_task():
result = celery_task.delay()
celery_task = CeleryModel(celery_task_id = result.id)
celery_task.save() # added save line
你的整数值是:celery_task.id
实际,独特celery_task_id对应。
更新:另一种方式......
首先python manage.py inspectdb > inspectdb.py
。在该文件中您将找到:
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'
接下来,python manage.py startapp celery_model
。将这个文件放在models.py文件中。我用南方,所以我最后一步将是python manage.py convert_app celery_model
。但是,它是不必要的。现在,您可以通过django级别访问该celery数据表,并且可以将每个任务的主键作为整数值读取。 E.g
>>> 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
有人聪明知道如何让你的CeleryTaskmeta
只读模式,因为我不认为你会想用数据表篡改。
UPDATE:你的问题的最后一部分:
>>> 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>
0
要获得芹菜任务ID的任务时,开始我做到以下几点:
process_task = my_task.apply_async(args=[args])
task_id = process_task.task_id
其中my_task距离的方法tasks.py
相关问题
- 1. 芹菜任务
- 2. 芹菜任务
- 3. 任务中的芹菜任务
- 4. 芹菜任务instanciation缓存
- 5. 获取芹菜每个任务日志
- 6. 获取芹菜中计划任务的任务ID
- 7. 在DB-Django中保存芹菜任务
- 8. 芹菜链任务
- 9. 推芹菜任务
- 10. 芹菜 - 获取当前任务的任务ID
- 11. 芹菜 - 如何记录父任务ID?
- 12. Djcelery:如何芹菜任务状态保存到数据库
- 13. 芹菜任务的属性
- 14. Python芹菜 - 如何在其他任务中调用芹菜任务
- 15. 芹菜的消息格式是每个任务还是每个任务的呼叫ID?
- 16. 芹菜任务更新两个数据库
- 17. 如何从先前的芹菜任务中产生芹菜任务?
- 18. 如何在芹菜中的任务组之后排列任务?
- 19. Django芹菜任务记录
- 20. 芹菜任务更新
- 21. Heroku芹菜背景任务
- 22. 芹菜任务链取消?
- 23. unittest芹菜任务assertRaises
- 24. 子类化芹菜任务
- 25. 芹菜任务消失
- 26. 去抖芹菜任务?
- 27. 芹菜任务不执行
- 28. 慢芹菜任务时间
- 29. 芹菜任务剖析
- 30. 芹菜任务计划
谢谢你彻底和清晰的解释! – pynovice 2013-03-05 06:34:28
问题是我想在进程启动时检索task_id。原来数据只有在作业成功完成后才写入CeleryTaskMeta表中。 – pynovice 2013-03-09 05:54:56
@Cole你如何在数据库中存储异步擦除的结果? – losee 2016-09-11 03:09:06