我正在使用Mongoengine和Django,我的项目需要在单个请求中连接两个MongoDB实例。如果我使用以下代码,它可以正常工作:
connect("mdb1")
#do stuff with mdb1
...
connect("mdb2")
#do stuff with mdb2
但我想知道这是否是正确的做法。
connect("mdb1")
#do stuff with mdb1
...
connect("mdb2")
#do stuff with mdb2
但我想知道这是否是正确的做法。
MongoEngine 0.6添加了对多个数据库的支持。
使用register_connection
演示。
alias_lists = ['users-books-db', 'user-db', 'book-db'] # list of aliases
dbs = ['author-book-pairs', 'users', 'books'] # list of databases
for alias, db in zip(alias_lists, dbs):
register_connection(alias, db)
class User(Document):
name = StringField()
meta = {"db_alias": "user-db"}
class Book(Document):
name = StringField()
meta = {"db_alias": "book-db"}
class AuthorBooks(Document):
author = ReferenceField(User)
book = ReferenceField(Book)
meta = {"db_alias": "users-books-db"}
users-db
中的User
类切换到新的数据库archive-user-db
中。from mongoengine.context_managers import switch_db
class User(Document):
name = StringField()
meta = {"db_alias": "user-db"}
with switch_db(User, 'archive-user-db') as User:
User(name="Ross").save() # Saves the 'archive-user-db'