mongodb异步python库motor(python在tornado中使用motor异步调用mongo)

Motor提供了一个基于协程的API,用于从Tornado或asyncio到MongoDB的非阻塞访问。

快速开始

1、安装

pip install motor

2、创建连接

from motor.motor_tornado import MotorClient
# mongo单机连接方式
client = MotorClient(host="127.0.0.1", port=27017)

# mongo集群连接方式
client = MotorClient(['127.0.0.1:27017', '127.0.0.1:27018'])

3、插入

db:数据库名 collection:集合名(表名) query:查询条件 doc:要存入的单条数据

# 插入单条
clinet[db][collection].insert_one(doc)
# 插入多条
clinet[db][collection].insert_many([doc,doc,...]])

4、删除

# 删除单条
clinet[db][collection].delete_one(query)
# 删除多条
clinet[db][collection].delete_many(query)

5、修改

# 修改单条
clinet[db][collection].update_one(query, doc)
# 修改多条
clinet[db][collection].update_many(query,doc)

6、 查找

# 获取数量
clinet[db][collection].count_documents(query)
# 查询单条
clinet[db][collection].find_one(query)
# 查询多条
clinet[db][collection].find(query)

7、注意

查询多条(find)结果的获取

1、循环获取所有结果

data_list = clinet[db][collection].find(query)
while (yield data_list.fetch_next):
    doc = data_list.next_object()

2、获取指定条数

例如参数length=1000是获取1000条

data_list = clinet[db][collection].find(query)
yield data_list.to_list(length=1000)
mongo  motor 
更新时间:2019-11-14 15:12:14

本文由 智慧煮粥 创作,如果您觉得本文不错,请随意赞赏
采用 知识共享署名4.0 国际许可协议进行许可
本站文章除注明转载/出处外,均为本站原创或翻译,转载前请务必署名
原文链接:http://zz.zzhub.cn/archives/pythontornadomotormongo
最后更新:2019-11-14 15:12:14

评论

Your browser is out of date!

Update your browser to view this website correctly. Update my browser now

×