python查詢mongodb內數據

来源:http://www.cnblogs.com/wuhl-89/archive/2017/11/03/7776779.html
-Advertisement-
Play Games

初學者,寫的不好請指出。 #第一步以insertTime為條件查詢時間段內的數據 #第二部步可以選擇是否再以通話Id為條件篩選第一步所查詢出來的數據 #因為使用的是配置文件,所以首先在代碼當前目錄下創建一個配置文件,db.conf 代碼: ...


初學者,寫的不好請指出。

#第一步以insertTime為條件查詢時間段內的數據

#第二部步可以選擇是否再以通話Id為條件篩選第一步所查詢出來的數據

#因為使用的是配置文件,所以首先在代碼當前目錄下創建一個配置文件,db.conf

代碼:

  1 import configparser
  2 import pymongo
  3 from pymongo import MongoClient
  4 import time
  5 
  6 print('以insertTime為條件查詢;可以按通話id篩選數據')
  7 count = 0
  8 f = open('獲取數據.txt', 'w',encoding='utf-8')  #在寫入文件夾是會報編碼格式錯誤,所以增加encoding='utf-8'解決
  9 cf =configparser.ConfigParser()
 10 #讀取當前目錄下的配置文件db.conf
 11 cf.read('db.conf')
 12 get_start_time = cf.getint('mongodb','start_time')
 13 get_end_time = cf.getint('mongodb','end_time')
 14 get_call_id = cf.get('mongodb','call_id')
 15 #將時間戳毫秒轉換為秒,db內的時間戳為毫秒單位,python的time為秒單位,所以除以1000
 16 s_local_time = time.localtime(get_start_time/1000)
 17 e_local_time = time.localtime(get_end_time/1000)
 18 #將秒轉換為日期格式2017-01-01 12:00:00
 19 s_time = time.strftime('%Y-%m-%d %H:%M:%S',s_local_time)
 20 e_time = time.strftime('%Y-%m-%d %H:%M:%S',e_local_time)
 21 
 22 print('資料庫IP:',cf.get('mongodb','db_ip'),'\n資料庫Port:',cf.getint('mongodb','db_port'))
 23 print('查詢開始時間:',s_time,'\n查詢結束時間:',e_time)
 24 print('通話ID:',get_call_id)
 25 client = MongoClient(cf.get('mongodb','db_ip'),cf.getint('mongodb','db_port'))
 26 print('****************************************************')
 27 
 28 #異常處理,連接失敗走except pymongo.errors.ServerSelectionTimeoutError並退出,成功走else路徑。
 29 try:
 30     print('正在連接...')
 31     client.database_names() #檢查是否能獲取到資料庫列表,獲取不到說明連接失敗。
 32     print('連接成功...')
 33     print('****************************************************')
 34 except pymongo.errors.ServerSelectionTimeoutError:
 35     print('無法連接,請查看資料庫是否啟成功,或資料庫IP和Port是否配置正確。')
 36     print('****************************************************')
 37 else:
 38     # 輸出資料庫列表,迴圈輸出
 39     print('資料庫名稱列表:')
 40     database_names_num = 1  #為資料庫編號,從1開始,迴圈一次+1
 41     for d_list in client.database_names():
 42         print(database_names_num,':',d_list)
 43         database_names_num += 1
 44     print('****************************************************')
 45     while True:
 46         #異常處理,如輸入非整數走下一步except ValueError,重新開始迴圈。否則走else路徑。
 47         try:
 48             num_1 = int(input('請以編號選擇資料庫:'))
 49         except ValueError:
 50             print('輸入類型錯誤,請重新輸入。')
 51             print('****************************************************')
 52         else :
 53             #判斷輸入的編號是否大於資料庫的數量,或小於1
 54             if num_1 > len(client.database_names()) or num_1 < 1 :
 55                 print('沒有找到這個資料庫,請重新輸入。')
 56                 print('****************************************************')
 57             else:
 58                 #因資料庫實際全部存在為一個列表內,索引從0開始,我們為資料庫設置的編號為從1開始,所以需要-1
 59                 db = client[client.database_names()[num_1-1]]   #資料庫名稱
 60                 print('****************************************************')
 61                 #print(db)
 62 
 63                 #列出資料庫內集合列表,迴圈輸出
 64                 print('資料庫內集合列表:')
 65                 collection_names_num = 1    #為集合編號,從1開始,迴圈一次+1
 66                 for c_list in db.collection_names():
 67                     print(collection_names_num, ':',c_list )
 68                     collection_names_num += 1
 69                 print('****************************************************')
 70 
 71                 while True:
 72                     # 異常處理,如輸入非整數走下一步except ValueError,重新開始迴圈。否則走else路徑。
 73                     try:
 74                         num_2 = int(input('請以編號選擇資料庫集合:'))
 75                         print('****************************************************')
 76                     except ValueError:
 77                         print('輸入類型錯誤,請重新輸入。')
 78                         print('****************************************************')
 79                     else:
 80                         # 判斷輸入的編號是否大於資料庫內集合的數量,或小於1
 81                         if num_2 > int(len(db.collection_names())) or num_2 < 1:
 82                                 print('沒有找到這個集合,請重新輸入。')
 83                                 print('****************************************************')
 84                             #print(db.collection_names())
 85                         else:
 86                             # 因資料庫集合實際全部存在為一個列表內,索引從0開始,我們為資料庫集合設置的編號為從1開始,所以需要-1
 87                             my_db = db[db.collection_names()[num_2-1]]
 88                             #print(my_db)
 89                             n = input('是否需要篩選通話id,輸入“Y”或“N”:')
 90                             print('****************************************************')
 91                             print('開始運行...')
 92 
 93                             #這個迴圈分為3條路徑,輸入n,y個一條,然後輸入別的任何字元走else路徑,並重新迴圈
 94                             while True:
 95                                 if n == 'n' or n == 'N':
 96                                     s__time = time.clock()  # 本地開始查詢時間
 97                                     #find查詢條件,查詢到符合條件的數據存到變數data
 98                                     for data in my_db.find({"insertTime": {'$gte': get_start_time, '$lte': get_end_time}}):
 99                                         #print(data)
100                                         f.write(str(data) + '\n')   #寫入文件內
101                                         count += 1  #統計共輸出數據的條數,初始為0,迴圈一次+1
102                                     e__time = time.clock()   #本地結束查詢時間
103                                     #耗時等於結束時間減去開始時間
104                                     print('運行結束,共查詢到', count, '條數據,共耗時',int(e__time - s__time), '秒。')
105                                     break
106 
107                                 elif n == 'y' or n =='Y':
108                                     # 開始運行時間
109                                     s__time = time.clock()  # 本地開始查詢時間
110                                     # find查詢條件,查詢到符合條件的數據存到變數data
111                                     for data in my_db.find({"insertTime": {'$gte': get_start_time, '$lte': get_end_time}}):
112                                         #k為key,v為value,迴圈遍歷data,查詢value內含有通話ID的數據寫入到文件
113                                         for k, v in data.items():
114                                             if get_call_id in str(v):
115                                                 #print(data)
116                                                 f.write(str(data) + '\n')
117                                                 count += 1  #統計共輸出數據的條數,初始為0,迴圈一次+1
118                                     e__time = time.clock()  #本地結束查詢時間
119                                     # 耗時等於結束時間減去開始時間
120                                     print('運行結束,共查詢到', count, '條數據,共耗時', int(e__time - s__time), '秒。')
121                                     break
122                             break
123                 break
124 input('按回車鍵結束...')

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • TensorFlow運行方式。載入數據、定義超參數,構建網路,訓練模型,評估模型、預測。 構造一個滿足一元二次函數y=ax^2+b原始數據,構建最簡單神經網路,包含輸入層、隱藏層、輸出層。TensorFlow學習隱藏層、輸出層weights、biases。觀察訓練次數增加,損失值變化。 生成、載入數 ...
  • decode的作用是將其他編碼的字元串轉換成unicode編碼,如str1.decode('gb2312'),表示將gb2312編碼的字元串str1轉換成unicode編碼。encode的作用是將unicode編碼轉換成其他編碼的字元串,如str2.encode('gb2312'),表示將unico ...
  • 一、幾種枚舉類代碼示例 1、最簡單枚舉類 2、一般枚舉類用法 二、枚舉類方法 1、values()方法,返回一個enum實例的數組,數組中元素嚴格保持其在enum中聲明時的順序 2、ordinal(),返回該enum實例在enum中聲明的次序(從0開始) 3、compareTo()方法,比較enum ...
  • 什麼是框架 ...
  • 1、整數轉二進位 2、搖骰子游戲 3、猜密碼 4、查詢天氣 首先創建city.py ...
  • 人生得意須盡歡,莫使金樽空對月。 先天下之憂而憂,後天下之樂而樂。 大東北的天氣已經漸入佳境了,在夜深人靜的時候,隨著滑鼠的移動,鍵盤清脆的聲音,開啟了今天的睡前代碼工程!今天聊聊JDBC版本的分頁,分頁功能在很多的web項目中都是必須的功能,然而分頁有真假分頁,假分頁,例如某某某網站,你懂得。什麼 ...
  • Spring簡介 網站: 複雜的Java EE項目用Spring才會得到優化,如果太簡單的項目用框架反而會變的麻煩。 ...
  • 背景 最近興趣使然寫了幾個Python庫,也發佈到了Pypi上,雖然沒什麼人下載,但自己在其他機器上用著也會很方便。這裡我向大家介紹一下如何在Pypi上發表自己的Python庫。 準備 註冊賬號 很顯然地要在Pypi上註冊一個賬號。 安裝必要的庫 setuptools 原則上安裝了pip的環境都有s ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...