Django рабочий процесс с использованием сигналов и сельдерея-джанго

Question

Я работаю над внедрением механизма рабочего процесса в свой проект, и основная цель моей попытки - создать переносимое приложение.Что-то, я мог бы поместить в любой другой проект в будущем, а затем присоединить рабочие процессы к различным моделям в моих проектах и ​​заставить его работать.

Я пытался придумать подход, но он не кажется идеальным.Я думал о создании приложения рабочего процесса внутри моего проекта, присоединяя два вида моделей, некоторые из них будут содержать настройку рабочего процесса (рабочий процесс, шаги, действия), а другие модели будут содержать экземпляры / транзакции.

Ниже приведен мой рабочий процесс / models.py

from django.db import models
from django.contrib.contenttypes.models import ContentType
from django.contrib.contenttypes import generic
import signals


################################
#   Workflow engine models
################################

class Signal_Listener(models.Model):
    LISTENING_ON = (
    ('I', 'INSERT'),
    ('U', 'UPDATE'),
    ('D', 'DELETE'),
    ('S', 'SELECT'),
    ('A', 'ANY QUERY'),
    ('L', 'ANY DDL'),
    )

    table_name = models.CharField(max_length=100)
    listening_to = models.CharField(max_length=1, choices=LISTENING_ON)

    class Meta:
        unique_together = (("table_name", "listening_to"),)

    def __unicode__(self):
        return '%s - %s' % (self.table_name, self.listening_to)

class Action(models.Model):
    ACTION_TYPE_CHOICES = (
    ('P', 'Python Script'   ),
    ('C', 'Class name'      ),
    )
    name = models.CharField(max_length=100)
    action_type = models.CharField(max_length=1, choices=ACTION_TYPE_CHOICES)
    audit_obj = generic.GenericRelation('core.Audit', editable=False)

class Steps(models.Model):
    sequence = models.IntegerField() 
    Action = models.ForeignKey(Action)
    Signal_Listener = models.ForeignKey(Signal_Listener)

class Process(models.Model):
## TODO: Document
# Processes class is used to store information about the process itself.
# Or in another word, the workflow name.
    WF_TYPE_LIST = (
    ('P', 'Python-API'),
    )

    name = models.CharField(max_length=30)
    is_active = models.BooleanField()
    wf_type = models.CharField(max_length=1, choices=WF_TYPE_LIST)
    audit_obj = generic.GenericRelation('core.Audit', editable=False)
    listening_to = models.ForeignKey(Steps)



################################
#   Workflow transactions models
################################

class Instance(models.Model):
##  TODO: Document
# Re
    INSTANCE_STATUS = (
    ('I', 'In Progress' ),
    ('C', 'Cancelled'   ),
    ('A', 'Archived'     ), # Old completed tasks can be archived
    ('P', 'Pending'     ),
    ('O', 'Completed'   )
    )

    id = models.CharField(max_length=200, primary_key=True)
    status = models.CharField(max_length=1, choices=INSTANCE_STATUS, db_index=True)
    audit_obj = generic.GenericRelation('core.Audit', editable=False)

    def save(self, *args, **kwargs):
    # on new records generate a new uuid
        if self.id is None or self.id.__len__() is 0:
            import uuid

            self.id = uuid.uuid4().__str__()
        super(Instances, self).save(*args, **kwargs)

class Task(models.Model):
    TASK_STATUS = (
    ('S', 'Assigned'    ),
    ('I', 'In Progress' ),
    ('P', 'Pending'     ),
    ('C', 'Cancelled'   ),
    ('A', 'Archived'    ), # Old completed tasks can be archived
    ('O', 'Completed'   )
    )
    name = models.CharField(max_length=100)
    instance = models.ForeignKey(Instance)
    status = models.CharField(max_length=1, choices=TASK_STATUS)
    bio = models.CharField(max_length=100)
    audit_obj = generic.GenericRelation('core.Audit', editable=False)

, и у меня также есть рабочий процесс / signal.py

    """
        Workflow Signals
            Will be used to monitor all inserts, update, delete or select statements
            If an action is attached to that particular table, it will be inserted Celery-Tasks distribution.
    """
    from django.db.models.signals import post_save, post_delete
    from django.core.cache import cache


    def workflow_post_init_listener(sender, **kwargs):
        try:

            if cache.get('wf_listner_cache_%s' % kwargs['instance']._meta.db_table):
                pass
            else:
                record = 'Signal_Listener'.objects.get(table_name__exact=kwargs['instance']._meta.db_table)
# am not sure what to do next!
        except 'Signal_Listener'.DoesNotExist:
            # TODO: Error logging
            pass

    post_save.connect(workflow_post_init_listener, dispatch_uid="workflow.models.listener.save")

Я думаю, что мой дизайн модели может потребоватьсябыть улучшено, а также.Я мог бы использовать в нескольких сценариях, и я думал начать с цикла утверждения, например, я мог бы вставить table_name / model_name в signal_listener для отслеживания новых вставок.Если это так, я запустлю определенный рабочий процесс.

Что касается действий, я понимаю, что действия должны быть разработаны.Может быть, мне нужно будет создать папку действий в приложении рабочего процесса, поместить каждое действие в класс.Каждый будет выполнять определенную задачу по отправке электронных писем, архивированию, обновлению значения базы данных… и т. Д.

Если я заново изобретаю колесо и если есть такая вещь, которая уже разработана, любой может подсказать, я бы большечем рад пройти через это.

С уважением,

Answer 1

Например, вы можете посмотреть на zope.wfmc (http://pypi.python.org/pypi/zope.wfmc): это реализация Коалиции управления потоком работ Рабочий процесс, который можно определить в XPDL.