使用Djongo把mongoDB连接到Django的踩坑记录

使用Djongo把mongoDB连接到Django

djongo

安装

1. 必须完全按照以下版本安装引用来源

   asgiref==3.5.0
   Django==4.0.3
   djongo==1.3.6
   dnspython==2.2.1
   pymongo==3.12.1
   python-snappy==0.6.1
   pytz==2022.1
   sqlparse==0.2.4
   

2. 在您的项目settings.py文件中，添加：

   DATABASES = {
       'default': {
           'ENGINE': 'djongo',
           'NAME': 'your-db-name',
       }
   }
   

setting.py配置数据库

DATABASES = {
        'default': {
            'ENGINE': 'djongo',
            'NAME': 'mdb',
            'ENFORCE_SCHEMA': False,
            'CLIENT': {
                'host': 'ip',
                'port': 27017,
                'username': 'xx',
                'password': 'xx',
                'authSource': 'mdb',
                'authMechanism': 'SCRAM-SHA-1'
            },
        }
    }

定义模型

Blog是一个抽象类，相当于二级集合，在下面Entry集合中的blog字段里面用

from djongo import models

class Blog(models.Model):
    name = models.CharField(max_length=100)

    class Meta:
        abstract = True

class Entry(models.Model):
    blog = models.EmbeddedField(
        model_container=Blog
    )    
    headline = models.CharField(max_length=255)    

在view的自定义函数中这样用。通过字典的形式给blog集合内的值赋值

e = Entry()
e.blog = {
    'name': 'Djongo'
}
e.headline = 'The Django MongoDB connector'
e.save()

报错处理

1. Array and Embedded Fields vs Error Abstract models cannot be instantiated

在读取数据库时报错，抽象类不能被实例化。说明blog这个字段出现了问题，无法读取数据库

解决办法

• 根据文档的说法在Model模型中添加一个objects字段，示例如下

  class Entry(models.Model):
  blog = models.EmbeddedField(
      model_container=Blog,
  )
  headline = models.CharField(max_length=255)    
  objects = models.DjongoManager()    
  

• 添加objects字段后就就可以使用pymongo的命令来读取数据库了

  index = [i for i in Entry.objects.mongo_aggregate([
              {
                  '$match': {
                      'headline': 'xx'
                  }
              },
          ])]
  
  return index
  

2.Object of type ‘ObjectId’ is not JSON serializable

读取数据库后通过JsonResponse返回报错

mongodb读取后返回的是一个orderdict（有序字典）它是有元素的先后顺序的。通过Json.load也无法将其格式化。

解决办法

from bson import json_util
 
data = json_util.dumps(data)
return HttpResponse(data)