在Post_save域触发M2M信号

Question

此代码应在每次创建新对象时将项添加到索引中。它可以工作，但没有意识到正在创建M2M字段。

我相信信号不会“看到”标签(因为它是一个M2M字段)。

换言之：

• 仅在“创建”对象时将标题字段添加到索引中。
• 只在单击“保存”时将M2M关系添加到索引中。

这是弹性搜索的索引。

Models.py

class Item(models.Model):
    title = models.CharField("Title", max_length=10000, blank=True)
    tag = models.ManyToManyField('Tag', blank=True)

    def get_grouped_tags(self):
        tag = self.tag.order_by('taglevel')
        grouped_tags = {
            tag_level: [
                { 'name': tag_of_level.name, 'taglevel': tag_of_level.taglevel, }
                for tag_of_level in tags_of_level
            ] for tag_level, tags_of_level
            in groupby(tag, lambda tag: tag.taglevel)
        }
        return grouped_tags

    def to_search(self):
        d = {
            "tags": self.grouped_tags(),
            "title": self.title
        }
        return ItemIndex(meta={'id': self.id}, **d)

    def indexing(self):
        obj = ItemIndex(
            meta={'id': self.id},
            title=self.title,
            typeItem=self.get_typeItem_display()
        )
        obj.save()
        return obj.to_dict(include_meta=True)

def update_search(instance, **kwargs):
    instance.to_search().save()

def remove_from_search(instance, **kwargs):
    instance.to_search().delete()

post_save.connect(update_search, sender=Item)
post_save.connect(update_search, sender=Tag)
pre_delete.connect(remove_from_search, sender=Item)
pre_delete.connect(remove_from_search, sender=Tag)
m2m_changed.connect(update_search, sender=Item)

Search.py

connections.create_connection()

class ItemIndex(DocType):
    title = String()
    class Meta:
        index = 'Item-index'


def bulk_indexing():
    ItemIndex.init()
    es = Elasticsearch()
    bulk(client=es, actions=(b.indexing() for b in models.Item.objects.all().iterator()))


def _search(title):
    s = Search().filter('term', title=title.text)
    response = s.execute()
    return response

Answer 1

明白了!与m2m_changed有关。我需要创建一个“通过”方法。

唯一需要改变的是：

m2m_changed.connect(update_search, sender=Item.tag.through)