Я импортировал некоторые метрические события в проект Django.Затем я сгруппировал события в сеансы, определенные как последовательность непрерывных событий в пределах данного временного окна.
Мой models.py выглядит так:
from django.db import models
from django.contrib.auth.models import User
class Event(models.Model):
name = models.CharField(max_length=255, blank=True, db_index=True)
id1 = models.CharField(max_length=255, blank=True, db_index=True)
id2 = models.CharField(max_length=255, blank=True)
time = models.DateTimeField(db_index=True)
user = models.ForeignKey(User, related_name='events', null=True, db_index=True)
session = models.ForeignKey('Session', related_name='events', null=True, db_index=True)
def __unicode__(self):
return '"%s" event' % self.name or 'unnamed'
class Session(models.Model):
user = models.ForeignKey(User, related_name='sessions', null=True)
Я сейчас пытаюсьденормализовать время начала и окончания этих сеансов, чтобы избежать необходимости выполнять агрегацию MAX и MIN для всех событий сеансов.Итак, моя новая модель Session выглядит следующим образом.
class Session(models.Model):
user = models.ForeignKey(User, related_name='sessions', null=True)
start = models.DateTimeField(db_index=True, null=True)
end = models.DateTimeField(db_index=True, null=True)
Я добавил поля, создал миграцию схемы (которая работает нормально) и создал миграцию данных:
import datetime
from south.db import db
from south.v2 import DataMigration
from django.db import models
class Migration(DataMigration):
def forwards(self, orm):
"Write your forwards methods here."
orm.Session.objects \
.annotate(
start_time=models.Min('events__time'),
end_time=models.Max('events__time')) \
.update(start=models.F('start_time'), end=models.F('end_time'))
def backwards(self, orm):
"Write your backwards methods here."
pass
models = {
'auth.group': {
...
'metrics_import.event': {
'Meta': {'object_name': 'Event'},
'id': ('django.db.models.fields.AutoField', [], {'primary_key': 'True'}),
'id1': ('django.db.models.fields.CharField', [], {'db_index': 'True', 'max_length': '255', 'blank': 'True'}),
'id2': ('django.db.models.fields.CharField', [], {'max_length': '255', 'blank': 'True'}),
'name': ('django.db.models.fields.CharField', [], {'db_index': 'True', 'max_length': '255', 'blank': 'True'}),
'session': ('django.db.models.fields.related.ForeignKey', [], {'related_name': "'events'", 'null': 'True', 'to': "orm['metrics_import.Session']"}),
'time': ('django.db.models.fields.DateTimeField', [], {'db_index': 'True'}),
'user': ('django.db.models.fields.related.ForeignKey', [], {'related_name': "'events'", 'null': 'True', 'to': "orm['auth.User']"})
},
'metrics_import.session': {
'Meta': {'object_name': 'Session'},
'end': ('django.db.models.fields.DateTimeField', [], {'null': 'True', 'db_index': 'True'}),
'id': ('django.db.models.fields.AutoField', [], {'primary_key': 'True'}),
'start': ('django.db.models.fields.DateTimeField', [], {'null': 'True', 'db_index': 'True'}),
'user': ('django.db.models.fields.related.ForeignKey', [], {'related_name': "'sessions'", 'null': 'True', 'to': "orm['auth.User']"})
}
}
Кажется достаточно простым, но запуск переноса данных дает:
django.db.utils.DatabaseError: no such column: metrics_import_event.time
Я проверил, что столбец действительно существует, оба из djangoshell:
>>> Event.objects.all()[0].time
datetime.datetime(2012, 1, 19, 3, 0, 3)
и непосредственно в схеме БД:
sqlite> .schema metrics_import_event
CREATE TABLE "metrics_import_event" (
"id" integer NOT NULL PRIMARY KEY,
"name" varchar(255) NOT NULL,
"id1" varchar(255) NOT NULL,
"id2" varchar(255) NOT NULL,
"time" datetime NOT NULL,
"user_id" integer REFERENCES "auth_user" ("id"),
"session_id" integer
);
CREATE INDEX "metrics_import_event_3a04cc98" ON "metrics_import_event" ("time");
CREATE INDEX "metrics_import_event_52094d6e" ON "metrics_import_event" ("name");
CREATE INDEX "metrics_import_event_6b4dc4c3" ON "metrics_import_event" ("session_id");
CREATE INDEX "metrics_import_event_fbfc09f1" ON "metrics_import_event" ("user_id");
Я уверен, что что-то глупо, что мне не хватает, но не могу понять, что.
Спасибо!
Редактировать: Обратите внимание, что первоначальная миграция схемы была применена с --fake
, на случай, если это как-то важно.