0

我有这个简单的模型，它就像一个 rsync 配置，用于预先填写 celery 定期任务的字段。我第一次通过模型创建新的 rsync 配置时一切正常，并且正在创建新的定期任务而没有问题。当我尝试更改将更改任务参数等任务字段的某些字段时，我得到一个“IntegrityError 列名不是唯一的”我觉得它与模型保存方法有关，但我不确定如何修正它。有人有什么想法吗？

这是模型：

from django.forms import ModelForm
from djcelery.models import IntervalSchedule
from djcelery.models import PeriodicTask, IntervalSchedule
INTERVAL=(
    ('every=5','period 5 minutes'),
    )

class Customer(models.Model):
    """(Customer description)"""
    customername = models.CharField(blank=True, max_length=30)
    emailaddress = models.EmailField()
    phonenumber = models.CharField(blank=True, max_length=10)
    class Meta:
    verbose_name_plural = "Customer"
    def __unicode__(self):
        return self.customername

class RsyncConfig(models.Model):
    """(RsyncConfig description)"""
    cname = models.ForeignKey(Customer)
    rsyncname = models.CharField(blank=True, max_length=255)
    interval=models.CharField(max_length=8,choices=INTERVAL)
    fromip = models.IPAddressField(blank=True)
    source_dir = models.CharField(blank=True, max_length=255)
    destination_dir = models.CharField(blank=True, max_length=255)
    rsync_args = models.CharField(blank=True, max_length=255)

    class Meta:
        verbose_name_plural = "Rsync Config"

    def __unicode__(self):
        return self.cname.customername

这是 admin.py 表单。

from django.contrib import admin
from django import forms
from djcelery.models import PeriodicTask, IntervalSchedule
from newrsync.models import Customer,RsyncConfig

class CustomerAdmin(admin.ModelAdmin):
    class Meta:
        model = Customer

class RsyncConfigAdminForm(forms.ModelForm):
    list_display = ('customername', 'rsyncname','source_dir','destination_dir')
    class Meta:
        model = RsyncConfig

    def __init__(self, *args, **kwargs):
        super(RsyncConfigAdminForm,self).__init__(*args, **kwargs)

    def save(self, commit=True):
        interval = IntervalSchedule.objects.get(every=5,period="minutes")
        model = super(RsyncConfigAdminForm, self).save(commit = False)
        model.cname = self.cleaned_data['cname']
        model.rsyncname = self.cleaned_data['rsyncname']
        model.fromip = self.cleaned_data['fromip']
        model.source_dir = self.cleaned_data['source_dir']
        model.destination_dir = self.cleaned_data['destination_dir']
        model.rsync_args = self.cleaned_data['rsync_args']
        if commit:
            model.save()
        PeriodicTask.objects.get_or_create(
                interval=interval,
                task='apps.mftconfig.tasks.rsync_proc',
                args=['rsync', 
                    model.rsync_args,
                    model.source_dir,
                    model.destination_dir],
                kwargs = {},
                name = (model.cname," ",model.rsyncname),
                enabled=False
                )
        return model


class RsyncConfigAdmin(admin.ModelAdmin):
    form = RsyncConfigAdminForm
    list_display = ('cname', 'rsyncname','source_dir','destination_dir')


admin.site.register(Customer,CustomerAdmin)
admin.site.register(RsyncConfig,RsyncConfigAdmin)
4

1 回答 1

0

我基本上在保存新版本之前就删除了对象。这并不完美，但至少我绕过了 PeriodicTask 模型中的独特限制，现在希望它以后不会咬我。如果有人有任何建议，请！;-)

class RsyncConfigAdminForm(forms.ModelForm):
    list_display = ('customername','rsyncname','source_dir','destination_dir')
class Meta:
    model = RsyncConfig

def __init__(self, *args, **kwargs):
    super(RsyncConfigAdminForm,self).__init__(*args, **kwargs)

def save(self, commit=True):

    instance = super(RsyncConfigAdminForm, self).save(commit = False)
    instance.customername = self.cleaned_data['customername']
    instance.rsyncname = self.cleaned_data['rsyncname']
    instance.fromip = self.cleaned_data['fromip']
    instance.source_dir = self.cleaned_data['source_dir']
    instance.destination_dir = self.cleaned_data['destination_dir']
    instance.rsync_args = self.cleaned_data['rsync_args']
    interval = IntervalSchedule.objects.get(every=5,period="minutes")
    p=PeriodicTask.objects.filter(name=instance.rsyncname)
    p.delete()
    PeriodicTask.objects.get_or_create(
            interval=interval,
            task='apps.mftconfig.tasks.rsync_proc',
            args=['rsync',
                instance.rsync_args,
                instance.source_dir,
                instance.destination_dir],
            kwargs = {},
            name = (instance.rsyncname),
            enabled=True
            )
    if commit:
        instance.save()
    return instance
于 2012-03-07T16:04:16.733 回答