upgrade_offLineTask_20180719.py 842 B

12345678910111213141516171819202122232425262728293031
  1. # -*- coding: utf-8 -*-
  2. # !/usr/bin/env python
  3. """
  4. 从offlineTask里将datetimeAdded字段更改为 dateTimeAdded 与其他的统一
  5. """
  6. import os
  7. import sys
  8. #: current_dir - 2
  9. PROJECT_ROOT = os.path.join(os.path.abspath(os.path.split(os.path.realpath(__file__))[0] + "/.."), '..')
  10. sys.path.insert(0, PROJECT_ROOT)
  11. from script.base import init_env, get_logger
  12. logger = get_logger(__name__)
  13. init_env(interactive=True)
  14. from django.conf import settings
  15. from apps.web.management.models import OfflineTask
  16. OfflineTask.get_collection().update({}, {'$rename': {'datetimeAdded': 'dateTimeAdded'}}, multi=True)
  17. for ot in OfflineTask.objects():
  18. updated = ot.update(link=settings.CELERY_RESULT_URL_PREFIX + ot.link, result=ot.link)
  19. print '{0!r} updated(result={1})'.format(ot, updated)
  20. print 'finished'