這篇文章給大家介紹Python中如何使用MongoDB模塊,內(nèi)容非常詳細(xì),感興趣的小伙伴們可以參考借鑒,希望對大家能有所幫助。
創(chuàng)新互聯(lián)建站基于成都重慶香港及美國等地區(qū)分布式IDC機房數(shù)據(jù)中心構(gòu)建的電信大帶寬,聯(lián)通大帶寬,移動大帶寬,多線BGP大帶寬租用,是為眾多客戶提供專業(yè)服務(wù)器托管報價,主機托管價格性價比高,為金融證券行業(yè)資陽主機托管,ai人工智能服務(wù)器托管提供bgp線路100M獨享,G口帶寬及機柜租用的專業(yè)成都idc公司。
涉及到python和mongodb,那么安裝相應(yīng)的模塊四必不可少的,最簡單的安裝方法,或者非pip不可了。
# pip install pymongo==3.0.4
順便也記錄下源碼安裝的方式
# wget https://pypi.python.org/packages/source/p/pymongo/pymongo-2.8.tar.gz#md5=23100361c9af1904eb2d7722f2658114 --no-check-certificate # tar xf pymongo-2.8.tar.gz # cd pymongo-2.8 # python setup.py install
摘自一則日志
35783 s100 android 47 5 192.168.1.100 2015-09-05 08:03:19 strengthenHeroByHeroes {"consume_gold":{"ogold":2893821,"cgold":1700,"gold":2892121,"tag":"strengthenHeroByHeroes"},"taskInfo":[{"id":2310033,"progress":2,"status":0}],"delHeroList":{"id":102014,"id":102014,"id":102014,"id":102010,"id":102010},"id":100026,"olevel":46,"oexp":1700,"cexp":1700,"level":46,"exp":3400} 865982021462182 XiaoMi入庫mongodb的python腳本
[root@localhost opt]# cat analytical.py
#!/usr/bin/env python
#coding:utf8
import os,sys,json
from datetime import *
from pymongo import MongoClient
def ConMongo(host,port,cur_db,username,password):
client = MongoClient(host,port)
db = client[cur_db]
db.authenticate(username,password)
table = db.gamelogs
return table
def parseLog(logfile,table):
dic = {}
dl = []
with open(file_log) as fd:
for line in fd:
try:
tokens = line.strip().split('\t')
uid = tokens[0]
server = tokens[1]
system = tokens[2]
level = int(tokens[3])
vip_level = tokens[4]
ip = tokens[5]
time = datetime.strptime(tokens[6], "%Y-%m-%d %H:%M:%S") #將時間字符串轉(zhuǎn)換成時間格式
action = tokens[7]
result = json.loads(tokens[8]) #特殊字符串轉(zhuǎn)換成json格式
uuid = tokens[9]
if len(tokens) == 12:
channel = tokens[11]
else:
channel = ''
dic = {'uid':uid,'server':server,'system':system,'level':level,'vip_level':vip_level,'ip':ip,'time':time,'action':action,'result':result,'uuid':uuid,'channel':channel}
dl.append(dic)
if len(dl) == 10000:
table.insert_many(dl)
dl = []
except Exception,e:
print e, line
if len(dl) > 0:
table.insert_many(dl)
if __name__ == '__main__':
table = ConMongo('localhost',27017,'talefundb','talefun','123456')
try:
logfile = sys.argv[1]
parseLog(logfile,table)
except IndexError,e:
print e注意事項:
(1)insert_many參數(shù)是mongodb 3.0.4中新加的,允許你將一個大列表直接insert到mongodb數(shù)據(jù)庫中 (2)腳本中做了限制,如果字典中有2000個值,就向mongodb插入一次數(shù)據(jù),這樣在效率上得到了保證 (3)不建議直接復(fù)制腳本測試,很多粘貼出來后,很多制表符等會出現(xiàn)問題。我會吧腳本放在云盤上大家可以下載,測試用。

關(guān)于Python中如何使用mongodb模塊就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,可以學(xué)到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
新聞標(biāo)題:Python中如何使用mongodb模塊
網(wǎng)頁地址:http://www.chinadenli.net/article48/igghep.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站建設(shè)、軟件開發(fā)、網(wǎng)站改版、虛擬主機、、網(wǎng)站導(dǎo)航
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)