sql >> Database >  >> NoSQL >> MongoDB

Hoe ReferenceField-gegevens in mongoengine te krijgen?

Momenteel wordt dit niet rechtstreeks ondersteund, aangezien MongoEngine alleen de uitgebreide json-syntaxis van mongodb ondersteunt.

Het enige dat mongoengine onder de dekens doet, is het gebruik van json_utils van pymongo om de gegevens te dumpen. Er is geen reden waarom u het niet expliciet kunt gebruiken, bijvoorbeeld:

    from bson import json_util

    class Inbox(db.Document):
        from_user    = db.ReferenceField(User, required=True)
        subject      = db.StringField(max_length=255, required=True)
        created_at   = db.DateTimeField(default=datetime.now)
        messages     = db.ListField(db.EmbeddedDocumentField(Message))


        def to_json(self):
            data = self.to_mongo() // get the pymongo representation of the document
            data["from_user"] = {"User": {"username": self.from_user.username}}
            return json_util.dumps(data)

            User.drop_collection()

    ...

    Inbox.drop_collection()

    ross = User(username="Ross").save()
    Inbox(from_user=ross, subject="Mongoengine should make json easier").save()

    doc = Inbox.objects.only('from_user', 'subject', 'created_at').get()
    print doc.to_json()

    {"_id": {"$oid": "538c3d71c3d384172fe35393"}, 
     "from_user": {"User": {"username": "Ross"}}, 
     "subject": "Mongoengine should make json easier", 
     "created_at": {"$date": 1401703297198}, "messages": []}

Bijgewerkt

Voorbeeld met aangepaste queryset:

   from bson import json_util

    class CustomQuerySet(QuerySet):
         def to_json(self):
            return "[%s]" % (",".join([doc.to_json() for doc in self]))

    class Inbox(Document):
        from_user    = ReferenceField(User, required=True)
        subject      = StringField(max_length=255, required=True)
        created_at   = DateTimeField(default=datetime.now)
        messages     = ListField(EmbeddedDocumentField(Message))

        meta = {'queryset_class': CustomQuerySet}

        def to_json(self):
            data = self.to_mongo()
            data["from_user"] = {"User": {"username": self.from_user.username}}
            return json_util.dumps(data)

  ...
  ipdb> Inbox.objects.only('from_user', 'subject', 'created_at').to_json()
        '[{"_id": {"$oid": "538d84cbc3d3843eeeb5dbbe"}, 
           "from_user": {"User": {"username": "Ross"}}, 
           "subject": "Mongoengine should make json easier", 
           "created_at": {"$date": 1401787099246}, "messages": []}]'



  1. Proberen om redis en resque planner te starten binnen een rake-taak

  2. Is er een goede manier om popleden van de Redis Sorted Set te steunen?

  3. Kan mongorestore een enkel url-argument gebruiken in plaats van afzonderlijke argumenten?

  4. Mongodb:meerdere collecties of één grote collectie met index