pymongo insert/batchInsert
pymongo find/$or(或条查询)
$or条件查询时，必需是一个json数组。
mongo(ISODate)对应的python日期 datetime.datetime.utcnow()
import pymongo
import datetime
def t1():
'''
mongodb insert/batchInsert
'''
now = datetime.datetime.utcnow()
logs = [
{
"type": "scan_qrcode",
"public_open_id": "gh_9e230201a972",
"user_open_id": "oa_dFw6ilHppFX7HmqFKFExZE52o",
"qrcode_id": "8a2f948b46b83d6d014600776d0f3ac2",
"create_date": now
},
{
"type": "text",
"content": '在mongodb中创建日期的时候使用不同的方式创建的日期是不同的。',
"public_open_id": "gh_ef420121b875",
"user_open_id": "oa_eWwailHppmqFFX7HKFExFE5ro",
"create_date": now
},
{
"type": "scan_qrcode",
"public_open_id": "gh_201a9729e230",
"user_open_id": "oa_ilHppFX7HmqFKFdFw6ExZE52o",
"qrcode_id": "2f948b46b83d6d0146d08af3ac260077",
"create_date": now
}
]
conn = pymongo.MongoClient('localhost', 27017)
db = conn['sl0']
# print db.test1.batchInsert(logs)
print db.test1.insert(logs)
conn.close()
def t2():
'''
mongodb find
'''
conn = pymongo.MongoClient('localhost', 27017)
db = conn['sl0']
# rows = db.test1.find({"type": "scan_qrcode", 'user_open_id': 'oa_dFw6ilHppFX7HmqFKFExZE52o'})
rows = db.test1.find({"$or": [{"type": "scan_qrcode", 'user_open_id': 'oa_dFw6ilHppFX7HmqFKFExZE52o'}, {"type": "text"}]})
for row in rows:
print row
conn.close()
