使用 asyncio_mongo 在 mongodb 上插入

Insert on mongodb using asyncio_mongo

我有一个情况,我需要在 mongodb 上以异步模式添加数据,所以我使用 asyncio-mongodb 包来添加数据。

不填username/password就没问题,填username/password就出现这个错误:

asyncio_mongo._pymongo.errors.OperationFailure: {'code': 16544, 'ok': 1.0, 'n': 0, 'err': 'not authorized for insert on ty_mongodb_memory1.bi_mongo_driver_pos', 'connectionId': 256286}

我在此集合中以同步模式添加数据(username/password 是正确的)。

问题是什么?

每当您创建与 mongo 数据库的连接时,您必须填写 "DB" 参数

asyncio_mongo.Connection.create('hostname', 'port', 
                                username="user", 
                                password="password", 
                                db='PUT YOUR DB NAME HERE')