您的位置:首页 > 数据库 > Mongodb

python对于mongodb微博数据的操作

2018-01-21 22:12 459 查看
自己现在正在使用python对于mongdb数据库的一些内容查询筛选

#coding=utf-8
#!/usr/bin/python 
from pymongo import MongoClient

#打开uids.txt
f = open('/Users/pc/Desktop/beifen.txt', 'r')
#读取出uids的内容存入list1中
list1 = f.read()
#以回车符把list1转化为arrr(其中arr的每个元素都是字符串)
arr = list1.split("\n")
#把arr的每个元素转化为int型数据
#arr = [int(arr) for arr in arr if arr ]
#计算arr的长度
lens = len(arr)
print lens
#定义一个数组长度与arr相同,全部赋值为0(作为储存id的次数的数组)
arrynum = [0 for x in len(arr)]
j = 0
#建立MongoDB数据库连接
client = MongoClient('222.27.227.104',27017)
#连接所需数据库,test为数据库名
db=client.test
#遍历weibo中的对象
for i in db.weibo_pc.find():
flag = i.has_key("reId")
j = j+1
if flag == True:
print '正在进行这是第',j,'条数据'
arrynum[arr.index(str(i["reId"]))] = arrynum[arr.index(str(i["reId"]))] + 1
else:
print '正在进行这是第',j,'条数据'
arrynum[arr.index(str(i["oriId"]))] = arrynum[arr.index(str(i["oriId"]))] + 1
print arrynum
p = open('/Users/pc/Desktop/huizong.txt', 'w+')
for x in range (0,957650):
p.write(arr[x])
p.write(",")
p.write(str(arrynum[x]))
p.write("\n")
f.close()
p.close()
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  python 大数据