问题描述
所以目前我正在处理一个 Django 项目，我有两个不同的数据库。一个是 Postgresql，第二个是 Neo4j。我想要的是两个数据库之间的实时同步。我正在使用 Django-admin 面板在 Postgres 数据库中进行 crud 操作。现在我还希望neo4j 数据库中的每个crud 操作更新。但我不知道该怎么做。
解决方法
您可以选择几条路线。我认为您将希望将 Postgres 作为您的主要 Django 数据库并使用 Neo4j 作为辅助 DB，而不是由 Django 框架管理。您可以使用类似于 this post 的 Neo4j 客户端库来实现这一点，用于自己与图形数据库交互。
为了使 Neo4j 与 Django 管理的 Postgres 保持同步，我认为 signals 将成为您最好的朋友，特别是 post_save 信号。本质上，任何时候您保存 Django 模型时，该信号都会触发一个函数，您可以编写该函数以使用 Neo4j 客户端 API 来反映图形数据库中的更改。
但是，根据您的模型的复杂程度，在此处确定哪些字段已更改为仅更新这些字段可能会变得棘手。不久前我遇到了类似的问题，并使用了这个自定义 Mixin（我找不到原作者，但将其保留在我的笔记中）：
from django.forms import model_to_dict
import logging
logger = logging.getLogger(__name__)
class ModelDiffMixin(object):
"""
A model mixin that tracks model fields' values and provide some useful api
to know what fields have been changed.
"""
def __init__(self,*args,**kwargs):
super(ModelDiffMixin,self).__init__(*args,**kwargs)
self.__initial = self._dict
@property
def diff(self):
d1 = self.__initial
d2 = self._dict
diffs = [(k,(v,d2[k])) for k,v in d1.items() if v != d2[k]]
return dict(diffs)
@property
def has_changed(self):
return bool(self.diff)
@property
def changed_fields(self):
return self.diff.keys()
def get_field_diff(self,field_name):
"""
Returns a diff for field if it's changed and None otherwise.
"""
return self.diff.get(field_name,None)
def save(self,**kwargs):
"""
Saves model and set initial state.
"""
super(ModelDiffMixin,self).save(*args,**kwargs)
self.__initial = self._dict
@property
def _dict(self):
return model_to_dict(self,fields=[field.name for field in
self._meta.fields])
如果你在你的模型中实现了这个 Mixin 以与 Neo4j 同步，那么在 post_save 信号处理程序中你可以调用 model.diff 或 model.changed_fields 来查看哪些属性需要更新在 Neo4j 节点上，而不是删除整个节点并重新创建它和所有关系。