A. 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
B. python中mongodb怎麼連接其他伺服器的資料庫
對於mongo的操作,先安裝mongodb的python擴展,在你的命令行窗口上輸入:pip install pymongo,下面是例子,按需要修改
from pymongo import MongoClientimport timemongo_uri_auth = 'mongodb://user:password@localhost:27017/'#mongo有要驗證的話請自行替換user和passwordmongo_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"})print record
C. 各位大腦,如何把txt文件用python導入到mongoDB資料庫里txt裡面欄位是姓名學號成績
python 訪問 mongodb 需要先安裝 pymongo,如下:
pipinstallpymongo
txt 文件格式:
#coding=utf-8
frompymongoimportMongoClient
conn=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)
D. 怎樣使用python訪問mongodb
安裝驅動pymongo!
輸入命令:pip installpymongo
直接使用驅動
缺點:
不是全盤取代傳統資料庫(NoSQLFan:是否能取代需要看應用場景)
不支持復雜事務(NoSQLFan:MongoDB只支持對單個文檔的原子操作)
文檔中的整個樹,不易搜索,4MB限制?(NoSQLFan:1.8版本已經修改為16M)
特點(NoSQLFan:作者在這里列舉的很多隻是一些表層的特點):
文檔型資料庫,表結構可以內嵌
沒有模式,避免空欄位開銷(Schema Free)
分布式支持
查詢支持正則
動態擴展架構
32位的版本最多隻能存儲2.5GB的數據(NoSQLFan:最大文件尺寸為2G,生產環境推薦64位)
E. 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)F. 關於Python連接Mongodb資料庫的問題
用法錯了,應該是這樣子
>>> import pymongo
>>> client = pymongo.MongoClient("localhost", 27017)G. 請教一個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 MongoDBH. python怎麼連接mongodb
通過pymongo可以很容易的鏈接到mongodb,下面的代碼鏈接到本地mongodb,資料庫為mydb,並檢索出mycollection中的所有數據輸出,簡單的幾行代碼已經做了很多事情
frompymongoimportConnection
connection=Connection(『localhost',27017)
db=connection.mydb
collection=db.mycollection
fordocincollection.find():
docI. 請問如何用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 「;將已經寫好的腳本文件拖拽到當前游標位置,然後敲回車運行即可。J. 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)