mongodbpython連接
Ⅰ 請問如何用python將爬取的數據逐條傳入MongoDB資料庫,請大牛指點。
物信息、統計、網頁製作、計算等多個領域都體現出了強大的功能。python和其他腳本語言如java、R、Perl 一樣,都可以直接在命令行里運行腳本程序。工具/原料
python;CMD命令行;windows操作系統
方法/步驟
1、首先下載安裝python,建議安裝2.7版本以上,3.0版本以下,由於3.0版本以上不向下兼容,體驗較差。
2、打開文本編輯器,推薦editplus,notepad等,將文件保存成 .py格式,editplus和notepad支持識別python語法。
腳本第一行一定要寫上 #!usr/bin/python
表示該腳本文件是可執行python腳本
如果python目錄不在usr/bin目錄下,則替換成當前python執行程序的目錄。
3、編寫完腳本之後注意調試、可以直接用editplus調試。調試方法可自行網路。腳本寫完之後,打開CMD命令行,前提是python 已經被加入到環境變數中,如果沒有加入到環境變數,請網路
4、在CMD命令行中,輸入 「python」 + 「空格」,即 」python 「;將已經寫好的腳本文件拖拽到當前游標位置,然後敲回車運行即可。
Ⅱ python 怎樣通過遍歷以下文件後全部讀到mongodb資料庫中
python 訪問 mongodb 需要先安裝 pymongo,如下:
1pipinstallpymongotxt 文件格式:
代碼如下:
#coding=utf-=MongoClient('127.0.0.1',27017)#連接test資料庫,沒有則自動創建db=conn.test#使用students集合,沒有則自動創建students=db.students#打開學生信息文件,並將數據存入到資料庫withopen('students.txt','r')asf:forlineinf.readlines():#分割學生信息items=line.strip(' ').strip(' ').split(',')#添加到資料庫students.insert({'stu_id':items[0],'name':items[1],'grade':int(items[2])})#資料庫查詢學生信息並列印出來forsinstudents.find():print(s)
Ⅲ 請教一個python 鏈接mongodb問題
在這周學習Python tornado的過程中,接觸了新的資料庫mongo.
在剛開始連接的過程中,就出現了如下的問題,特此記錄一下。
AttributeError: 'mole' object has no attribute 'Connection'
python版本2.7.11
pymongo版本3.3.0
根據網上的教程,首先導入pymongo,連接第一步的步驟大都是如下的
import pymongo
conn = pymongo.Connection('localhost',27017)
然後就報錯啦啦啦啦!
AttributeError: 'mole' object has no attribute 'Connection'
然後發現我看的pymongo教程大都是幾年前的,pymongo的版本應該也比較低。
後面網路,google了一下,原來是新的pymongo中取消了Connection這個方法。
新的版本需要新建一個client,然後才是連接。
>>> from pymongo import MongoClient
>>> client=MongoClient()
>>> client
MongoClient('localhost', 27017)
mongo_client – Tools for connecting to MongoDB
Ⅳ python測試mongo連接是否有效
(1)先在mongodb中執行
ISODate("2015-02-01T00:00:00Z").valueOf()
會得到
1422748800000
(2)使用可以使用以下條件進行查詢
"lastAccessTime" : {$gte: new date(1422748800000)}
但是在python中會提示語法錯誤,
可以按照如下來解決:
from datetime import datetime
查詢條件可以寫成
"lastAccessTime" : {"$gte": datetime(2015, 2, 1)}
這樣就可以解決了。
Ⅳ Python語言怎麼實現mongodb的查詢操作
對於mongo的操作,先安裝mongodb的python擴展,在你的命令行窗口上輸入:pip install pymongo,下面是例子,按需要修改
frompymongoimportMongoClient
importtime
mongo_uri_auth='mongodb://user:password@localhost:27017/'#mongo有要驗證的話請自行替換user和password
mongo_uri_no_auth='mongodb://localhost:27017/'#mongo沒有賬號密碼驗證的時候用這個
database_name='request_db'#你要連接的資料庫名,自行替換你需要的庫名
table_name='request_tb'#你要查詢的表名,請自行替換你需要的表名
client=MongoClient(mongo_uri_no_auth)#創建了與mongodb的連接
db=client[database_name]
table=db[table_name]#獲取資料庫中表的游標
#你要插入的數據
insert_data={"name":"Mike","grade":"two","age":12,"sex":"man"}
table..insert_one(insert_data)#插入一條數據
#查詢數據name為Mike的記錄
record=table.find_one({"name":"Mike"})
printrecord
Ⅵ python怎麼操作mongodb
#coding:utf-8__author__ = 'hdfs'import pymongofrom pymongo import MongoClientclient = MongoClient() client=MongoClient('10.0.0.9',27017)#連接mongodb資料庫client = MongoClient('mongodb://10.0.0.9:27017/')#指定資料庫名稱db = client.test_database#獲取非系統的集合db.collection_names(include_system_collections=False)#獲取集合名posts = db.posts#查找單個文檔posts.find_one()#給定條件的一個文檔posts.find_one({"author": "Mike"})#使用ID查找需要ObjectIDfrom bson.objectid import ObjectIdpost_id='5728aaa96795e21b91c1aaf0'document = client.db.collection.find_one({'_id': ObjectId(post_id)})import datetimenew_posts = [{"author": "Mike", "text": "Another post!", "tags": ["bulk", "insert"], "date": datetime.datetime(2009, 11, 12, 11, 14)}, {"author": "Eliot", "title": "MongoDB is fun", "text": "and pretty easy too!", "date": datetime.datetime(2009, 11, 10, 10, 45)}]#插入多條記錄result = posts.insert_many(new_posts)#返回插入的IDresult.inserted_ids#遞歸集合for post in posts.find(): post #遞歸條件集合for post in posts.find({"author": "Mike"}): post #文檔的記錄數posts.count() #區間查詢d = datetime.datetime(2009, 11, 12, 12)for post in posts.find({"date": {"$lt": d}}).sort("author"): print post#給集合profiles建立索引 唯一索引result = db.profiles.create_index([('user_id', pymongo.ASCENDING)],unique=True)#查看索引信息list(db.profiles.index_information())#user_profiles = [{'user_id': 211, 'name': 'Luke'},{'user_id': 212, 'name': 'Ziltoid'}]result = db.profiles.insert_many(user_profiles) #聚合查詢from pymongo import MongoClientdb = MongoClient('mongodb://10.0.0.9:27017/').aggregation_example#准備數據result = db.things.insert_many([{"x": 1, "tags": ["dog", "cat"]}, {"x": 2, "tags": ["cat"]}, {"x": 2, "tags": ["mouse", "cat", "dog"]}, {"x": 3, "tags": []}])result.inserted_ids'''{ "_id" : ObjectId("576aaa973e5269020848cc7c"), "x" : 1, "tags" : [ "dog", "cat" ] }{ "_id" : ObjectId("576aaa973e5269020848cc7d"), "x" : 2, "tags" : [ "cat" ] }{ "_id" : ObjectId("576aaa973e5269020848cc7e"), "x" : 2, "tags" : [ "mouse", "cat", "dog" ] }{ "_id" : ObjectId("576aaa973e5269020848cc7f"), "x" : 3, "tags" : [ ] }'''from bson.son import SON#$unwind 解開-後面的變數pipeline = [ {"$unwind": "$tags"}, {"$group": {"_id": "$tags", "count": {"$sum": 1}}}, {"$sort": SON([("count", -1), ("_id", -1)])} ]list(db.things.aggregate(pipeline))#使用聚合函數with commanddb.command('aggregate', 'things', pipeline=pipeline, explain=True)
Ⅶ 怎樣使用python訪問mongodb
安裝驅動pymongo!
輸入命令:pip installpymongo
直接使用驅動
缺點:
不是全盤取代傳統資料庫(NoSQLFan:是否能取代需要看應用場景)
不支持復雜事務(NoSQLFan:MongoDB只支持對單個文檔的原子操作)
文檔中的整個樹,不易搜索,4MB限制?(NoSQLFan:1.8版本已經修改為16M)
特點(NoSQLFan:作者在這里列舉的很多隻是一些表層的特點):
文檔型資料庫,表結構可以內嵌
沒有模式,避免空欄位開銷(Schema Free)
分布式支持
查詢支持正則
動態擴展架構
32位的版本最多隻能存儲2.5GB的數據(NoSQLFan:最大文件尺寸為2G,生產環境推薦64位)
Ⅷ python 連mongodb時怎麼設定mongod服務端路徑
python連接mongodb操作數據示例,主要包括插入數據、更新數據、查詢數據、刪除數據等
一、相關代碼
資料庫配置類 MongoDBConn.py
復制代碼 代碼如下:
#encoding=utf-8
'''
Mongo Conn連接類
'''
import pymongo
class DBConn:
conn = None
servers = "mongodb://localhost:27017"
def connect(self):
self.conn = pymongo.Connection(self.servers)
def close(self):
return self.conn.disconnect()
def getConn(self):
return self.conn
MongoDemo.py 類
復制代碼 代碼如下:
#encoding=utf-8
'''
Mongo操作Demo
Done:
'''
import MongoDBConn
dbconn = MongoDBConn.DBConn()
conn = None
lifeba_users = None
def process():
#建立連接
dbconn.connect()
global conn
conn = dbconn.getConn()
#列出server_info信息
print conn.server_info()
#列出全部資料庫
databases = conn.database_names()
print databases
#刪除庫和表
dropTable()
#添加資料庫lifeba及表(collections)users
createTable()
#插入數據
insertDatas()
#更新數據
updateData()
#查詢數據
queryData()
#刪除數據
deleteData()
#釋放連接
dbconn.close()
def insertDatas():
datas=[{"name":"steven1","realname":"測試1","age":25},
{"name":"steven2","realname":"測試2","age":26},
{"name":"steven1","realname":"測試3","age":23}]
lifeba_users.insert(datas)
def updateData():
'''只修改最後一條匹配到的數據
第3個參數設置為True,沒找到該數據就添加一條
第4個參數設置為True,有多條記錄就不更新
'''
lifeba_users.update({'name':'steven1'},{'$set':{'realname':'測試1修改'}}, False,False)
def deleteData():
lifeba_users.remove({'name':'steven1'})
def queryData():
#查詢全部數據
rows = lifeba_users.find()
printResult(rows)
#查詢一個數據
print lifeba_users.find_one()
#帶條件查詢
printResult(lifeba_users.find({'name':'steven2'}))
printResult(lifeba_users.find({'name':{'$gt':25}}))
def createTable():
'''創建庫和表'''
global lifeba_users
lifeba_users = conn.lifeba.users
def dropTable():
'''刪除表'''
global conn
conn.drop_database("lifeba")
def printResult(rows):
for row in rows:
for key in row.keys():#遍歷字典
print row[key], #加, 不換行列印
print ''
if __name__ == '__main__':
process()Ⅸ 關於Python連接Mongodb資料庫的問題
用法錯了,應該是這樣子
>>> import pymongo
>>> client = pymongo.MongoClient("localhost", 27017)Ⅹ python中mongodb怎麼連接其他伺服器的資料庫
1、基於mongo實現遠程連接
[plain] view plain
mongo -u admin -p admin 192.168.0.197:27017/pagedb
通過mongo實現連接,可以非常靈活的選擇參數選項,參看命令幫助,如下所示:
[plain] view plain
mongo --help
MongoDB shell version: 1.8.3
usage: mongo [options] [db address] [file names (ending in .js)]
db address can be:
foo foo database on local machine
192.169.0.5/foo foo database on 192.168.0.5 machine
192.169.0.5:9999/foo foo database on 192.168.0.5 machine on port 9999
options:
--shell run the shell after executing files
--nodb don't connect to mongod on startup - no 'db address'
arg expected
--quiet be less chatty
--port arg port to connect to
--host arg server to connect to
--eval arg evaluate javascript
-u [ --username ] arg username for authentication
-p [ --password ] arg password for authentication
-h [ --help ] show this usage information
--version show version information
--verbose increase verbosity
--ipv6 enable IPv6 support (disabled by default)
2、基於MongoDB支持的javascript實現遠程連接
當你已經連接到一個遠程的MongoDB資料庫伺服器(例如,通過mongo連接到192.168.0.184),現在想要在這個會話中連接另一個遠程的資料庫伺服器(192.168.0.197),可以執行如下命令:
[plain] view plain
> var x = new Mongo('192.168.0.197:27017')
> var ydb = x.getDB('pagedb');
> use ydb
switched to db ydb
> db
ydb
> ydb.page.findOne()
{
"_id" : ObjectId("4eded6a5bf3bfa0014000003"),
"content" : "巴黎是浪漫的城市,可是...",
"pubdate" : "2006-03-19",
"title" : "巴黎:從布魯塞爾趕到巴黎",
"url" : "http://france.bytravel.cn/Scenery/528/cblsegdbl.html"
}
上述通過MongoDB提供的JavaScript腳本,實現對另一個遠程資料庫伺服器進行連接,操作指定資料庫pagedb的page集合。
如果啟用了安全認證模式,可以在獲取資料庫連接實例時,指定認證賬號,例如:
[plain] view plain
> var x = new Mongo('192.168.0.197:27017')
> var ydb = x.getDB('pagedb', 'shirdrn', '(jkfFS$343$_\=\,.F@3');
> use ydb
switched to db ydb