python mongo

Python 连接mongo数据库。昨天搞了很久,遇到了不少问题。简单记录一下。

比较常用的就是 find,update 操作。

find   操作

db.chats.find({‘createAt‘:{‘$gt‘:‘1418964444‘}});

上面的查询条件被封装成了一个字典。是一个严谨的json结构,需要注意的是 ‘$gt‘ 表示 greater than 的意思。例外需要注意的是这个每一个字段都是有类型的,

如果类型不对,是无法匹配的,所以在实际应用过程中需要注意。

如果find里面什么条件都没有,表示查找全部,这样可以查找出这个collections 中的所有数据。

setlimit 操作

可以限制查找的条数,这个也是很有用的。和mysql的 limit 是类似的。 第一个数字是offset,第二个是 limit。

db.user_online_status.find().limit(5,10)

update 操作。

 db.user_online_status.update({'user_id':'155739067'},{'$set':{'online_time':'1'}});

其中第一个json 是查找条件,相当于 sql 中update 的where 的条件。第二个json 部分是需要设置的值。这里的开头是‘$set‘,如果没有这个变量,那么表示整体更新,

加上这个字段之后就是部分更新了,当然实际过程中,大部分都是部分更新的。只更新目标文档的一部分内容。而不是完全用一个新的文档来替换旧的文档。文档就是

mongo里面的一个概念,实际就是一条数据。

例外mongo 里面的一些简单的操作。

mongo shell。

show collections; 查看数据库里所有的表。 collection 和 mysql 中的 table 的概念是一致的。

use yourdb;  切换到yourdb,和mysql 是一样的。

另外附上我写的一个简单的库。随手写的,用python 链接  mongo 的一个 db wrapper pyMongo 。

时间: 2024-10-25 22:21:35

python mongo的相关文章

Python Mongo操作

# -*- coding: utf-8 -*- ''' Python Mongo操作Demo Done: ''' from pymongo import MongoClient conn = None topics = None users=None def process(): connection=MongoClient('localhost', 27017) global conn conn = connection; #列出server_info信息 #print conn.server

Python Mongo数据库

目录 1.mongo的安装 2.mongo数据库操作 3.Python与Mongo交互 1. mongo的安装 (将安装目录下的bin目录添加到系统环境变量中) # mongo的配置: 1.创建数据库文件及日志文件目录, 并将目录写入配置文件 2.在系统终端执行以下命令: mongod --bind_ip 127.0.0.1 --logpath "D:\Professional\MongoDB\log\mongodb.log" - -logappend --dbpath "D

mongo db安装和php,python插件安装

安装mongodb 1.下载,解压mongodb(下载解压目录为/opt) 在/opt目录下执行命令 wget fastdl.mongodb.org/linux/mongodb-linux-x86_64-2.6.4.tgz tar xzvf mongodb-linux-x86_64-2.6.4.tgz 2.创建mongodb的数据文件和日志文件存放路径 mkdir -p /data/mongodb_data/{mongodb_log,mongodb_db} 创建数据文件路径 /data/mong

地铁译:Spark for python developers ---Spark的数据戏法

聚焦在 Twitter 上关于Apache Spark的数据, 这些是准备用于机器学习和流式处理应用的数据. 重点是如何通过分布式网络交换代码和数据,获得 串行化, 持久化 , 调度和缓存的实战经验 . 认真使用 Spark SQL, 交互性探索结构化和半结构化数据. Spark SQL 的基础数据结构是?Spark dataframe, Spark dataframe 受到了 Python Pandas?dataframe 和R dataframe 的启发. 这是一个强大的数据结构, 有R 或

Fluentd 例子

1. http输入,stdout输出 例子 <source> @type http port 8888 bind 0.0.0.0 </source> <match td3.**> type stdout </match> 请求 curl http://10.218.139.216:8888/td3 -d 'json={"hi":"abc"}' 结果(/var/log/td-agent/td-agent.log) 201

yum安装memcache,mongo扩展以及python的mysql模块安装

//启动memcached/usr/local/memcached/bin/memcached -d -c 10240 -m 1024 -p 11211 -u root/usr/local/memcached/bin/memcached -d -c 10240 -m 1024 -p 11212 -u root 1.安装mongodb mongodb安装在/usr/local/mongod 目录下mkdir /usr/local/mongod/data //存放数据, touch /usr/loc

【python】多进程与mongo

参考:http://api.mongodb.com/python/current/faq.html#using-pymongo-with-multiprocessing 如果使用了多进程,则必须在子进程中创建mongo连接.不能创建一个mongo连接传给多个进程!! # Each process creates its own instance of MongoClient. def func(): db = pymongo.MongoClient().mydb # Do something w

python公网连接阿里云mongo服务器

背景: 公司使用阿里云的云数据库MongoDB.基于安全原因考虑,阿里云MongoDB云数据库目前只支持从阿里云ECS上访问,无法通过公网直接访问,不方便用户在本地开发环境里直接进行测试. 阿里云官方推荐使用rinetd搭建跳板系统,实现公网访问云mongo.使用过程中,发现,python程序在使用过程中如果没有正确释放连接,即使python程序退出后,该mongo连接仍然被rinetd占用.曾出现调用该地址的python程序全部退出后,rinetd仍占用100多个连接,导致云mongo可用连接

python操作mongo脚本

#!/usr/bin/python# -*- coding: utf-8 -*- import sysimport osimport jsonfrom pymongo import MongoClientimport datetime #获取系统当前日期today = datetime.datetime.now() #取指定前几天的日期lastday = today + datetime.timedelta(days=-4) #连接mongod的方式采用urlclient = MongoClie