Python分析14億條數據,分分鐘就處理好了

来源:https://www.cnblogs.com/hahaa/archive/2023/02/13/17116668.html
-Advertisement-
Play Games

Google Ngram viewer是一個有趣和有用的工具,它使用谷歌從書本中掃描來的海量的數據寶藏,繪製出單詞使用量隨時間的變化。 舉個例子,單詞 Python (區分大小寫) : 這幅圖來自:books.google.com/ngrams… ,描繪了單詞 ‘Python’ 的使用量隨時間的變化 ...


Google Ngram viewer是一個有趣和有用的工具,它使用谷歌從書本中掃描來的海量的數據寶藏,繪製出單詞使用量隨時間的變化。

舉個例子,單詞 Python (區分大小寫) :

這幅圖來自:books.google.com/ngrams… ,描繪了單詞 ‘Python’ 的使用量隨時間的變化。

它是由谷歌的n-gram 數據集驅動的,根據書本印刷的每一個年份,記錄了一個特定單詞或片語在谷歌圖書的使用量。然而這並不完整(它並沒有包含每一本已經發佈的書!),數據集中有成千上百萬的書,時間上涵蓋了從 16 世紀到 2008 年。數據集可以免費從這裡下載。

我決定使用 Python 和我新的數據載入庫 PyTubes 來看看重新生成上面的圖有多容易。

挑戰

1-gram 的數據集在硬碟上可以展開成為 27 Gb 的數據,這在讀入 python 時是一個很大的數據量級。Python可以輕易地一次性地處理千兆的數據,但是當數據是損壞的和已加工的,速度就會變慢而且記憶體效率也會變低。

總的來說,這 14 億條數據(1,430,727,243)分散在 38 個源文件中,一共有 2 千 4 百萬個(24,359,460)單詞(和詞性標註,見下方),計算自 1505 年至 2008 年。

當處理 10 億行數據時,速度會很快變慢。並且原生 Python 並沒有處理這方面數據的優化。幸運的是, numpy 真的很擅長處理大體量數據。使用一些簡單的技巧,我們可以使用 numpy 讓這個分析變得可行。

在 python/numpy 中處理字元串很複雜。字元串在 python 中的記憶體開銷是很顯著的,並且 numpy 只能夠處理長度已知而且固定的字元串。基於這種情況,大多數的單詞有不同的長度,因此這並不理想。

# 兄弟們學習python,有時候不知道怎麼學,從哪裡開始學。掌握了基本的一些語法或者做了兩個案例後,不知道下一步怎麼走,不知道如何去學習更加高深的知識。
# 那麼對於這些大兄弟們,我準備了大量的免費視頻教程,PDF電子書籍,以及源代碼!
# 還會有大佬解答!
# 都在這個裙里了:708525271
# 歡迎加入,一起討論 一起學習!

 

Loading the data

下麵所有的代碼/例子都是運行在 8 GB 記憶體 的 2016 年的 Macbook Pro。如果硬體或雲實例有更好的 ram 配置,表現會更好。

1-gram 的數據是以 tab 鍵分割的形式儲存在文件中,看起來如下:

每一條數據包含下麵幾個欄位:

為了按照要求生成圖表,我們只需要知道這些信息,也就是:

通過提取這些信息,處理不同長度的字元串數據的額外消耗被忽略掉了,但是我們仍然需要對比不同字元串的數值來區分哪些行數據是有我們感興趣的欄位的。這就是 pytubes 可以做的工作:

差不多 170 秒(3 分鐘)之後, one_grams 是一個 numpy 數組,裡面包含差不多 14 億行數據,看起來像這樣(添加表頭部為了說明):

從這開始,就只是一個用 numpy 方法來計算一些東西的問題了:

每一年的單詞總使用量

谷歌展示了每一個單詞出現的百分比(某個單詞在這一年出現的次數/所有單詞在這一年出現的總數),這比僅僅計算原單詞更有用。為了計算這個百分比,我們需要知道單詞總量的數目是多少。

幸運的是,numpy讓這個變得十分簡單:

繪製出這個圖來展示谷歌每年收集了多少單詞:

很清楚的是在 1800 年之前,數據總量下降很迅速,因此這回曲解最終結果,並且會隱藏掉我們感興趣的模式。為了避免這個問題,我們只導入 1800 年以後的數據:

這返回了 13 億行數據(1800 年以前只有 3.7% 的的占比)

Python 在每年的占比百分數

獲得 python 在每年的占比百分數現在就特別的簡單了。

使用一個簡單的技巧,創建基於年份的數組,2008 個元素長度意味著每一年的索引等於年份的數字,因此,舉個例子,1995 就只是獲取 1995 年的元素的問題了。

這都不值得使用 numpy 來操作:

繪製出 word_counts 的結果:

形狀看起來和谷歌的版本差不多

實際的占比百分數並不匹配,我認為是因為下載的數據集,它包含的用詞方式不一樣(比如:Python_VERB)。這個數據集在 google page 中解釋的並不是很好,並且引起了幾個問題:

人們是如何將 Python 當做動詞使用的?

‘Python’ 的計算總量是否包含 ‘Python_VERB’?等

幸運的是,我們都清楚我使用的方法生成了一個與谷歌很像的圖標,相關的趨勢都沒有被影響,因此對於這個探索,我並不打算嘗試去修複。

性能

谷歌生成圖片在 1 秒鐘左右,相較於這個腳本的 8 分鐘,這也是合理的。谷歌的單詞計算的後臺會從明顯的準備好的數據集視圖中產生作用。

舉個例子,提前計算好前一年的單詞使用總量並且把它存在一個單獨的查找表會顯著的節省時間。同樣的,將單詞使用量保存在單獨的資料庫/文件中,然後建立第一列的索引,會消減掉幾乎所有的處理時間。

這次探索 確實 展示了,使用 numpy 和 初出茅廬的 pytubes 以及標準的商用硬體和 Python,在合理的時間內從十億行數據的數據集中載入,處理和提取任意的統計信息是可行的。

語言戰爭

為了用一個稍微更複雜的例子來證明這個概念,我決定比較一下三個相關提及的編程語言:Python,Pascal, 和 Perl.

源數據比較嘈雜(它包含了所有使用過的英文單詞,不僅僅是編程語言的提及,並且,比如,python 也有非技術方面的含義!),為了這方面的調整, 我們做了兩個事情:

只有首字母大寫的名字形式能被匹配(Python,不是 Python)

每一個語言的提及總數已經被轉換到了從 1800 年到 1960 年的百分比平均數,考慮到 Pascal 在 1970 年第一次被提及,這應該有一個合理的基準線。

結果:

對比谷歌 ( 沒有任何的基準線調整 ):


運行時間: 只有 10 分鐘多一點

以後的 PyTubes 提升

在這個階段,pytubes 只有單獨一個整數的概念,它是 64 比特的。這意味著 pytubes 生成的 numpy 數組對所有整數都使用 i8 dtypes。在某些地方(像 ngrams 數據),8 比特的整型就有點過度,並且浪費記憶體(總的 ndarray 有 38Gb,dtypes 可以輕易的減少其 60%)。

我計劃增加一些等級 1,2 和 4 比特的整型支持( github.com/stestagg/py… )

更多的過濾邏輯 - Tube.skip_unless() 是一個比較簡單的過濾行的方法,但是缺少組合條件(AND/OR/NOT)的能力。這可以在一些用例下更快地減少載入數據的體積。

更好的字元串匹配 —— 簡單的測試如下:startswith, endswith, contains, 和 is_one_of 可以輕易的添加,來明顯地提升載入字元串數據是的有效性。


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

-Advertisement-
Play Games
更多相關文章
  • ioc,Inversion of Control(控制反轉),是Spring中的一種設計思想而非技術。 我們可以從4個方面理解ioc: ①誰控制誰? ——Ioc容器控制對象。 ②控制了什麼? ——Ioc容器控制了獲取對象及其外部資源。 ③為什麼是反轉? ——傳統的javaSE技術是手動new對象的, ...
  • 這篇文章主要描述分散式系統中的單體調度機制,它是指一個集群中只有一個節點運行調度進程,並介紹Google Borg的單體調度設計思路。 ...
  • SpringMVC底層機制簡單實現-04 https://github.com/liyuelian/springmvc-demo.git 8.任務7-完成簡單視圖解析 功能說明:通過目標方法返回的 String,轉發或重定向到指定頁面 8.1分析 原生的 SpringMVC 使用視圖解析器來對 Ha ...
  • 一、說明 之前項目中一直使用ConcurrentLinkedQueue做為緩衝隊列(主要是單個項目內,單條改批量的場景,多個項目間使用的是rocketmq),雖然用著方便但是是純記憶體的, 如果項目發生異常崩潰記憶體隊列中的數據就會全部丟失(只能從日誌中恢復)。所以一直想找一個簡單高效支持持久化的嵌入式 ...
  • 書接上文,上回說到如何通過interactcli-rs四步實現一個命令行程式。但是 shell 交互模式在有些場景下用戶體驗並不是很好。比如我們要連接某個服務,比如 mysql 或者 redis 這樣的服務。如果每次交互都需要輸入地址、埠、用戶名等信息,交互起來太麻煩。通常的做法是一次性輸入和連接... ...
  • 教程簡介 Microsoft Azure初學者教程 - 從簡單和簡單的步驟學習Microsoft Azure,從基本到高級概念,包括雲計算概述,Windows Azure,組件,計算模塊,結構控制器,存儲,Blob,隊列,表,CDN,應用程式,安全性,數據中心,方案,管理門戶,創建虛擬網路,部署虛擬 ...
  • 本文主要記錄Maven依賴管理中關於依賴傳遞和依賴範圍的知識 Maven項目示例 創建3個maven項目,分配依賴log4j 1.2.12, 1.2.13, 1.2.14版本。 <!--項目1--> <groupId>com.leo</groupId> <artifactId>project1</a ...
  • 大家好我是Jack,一個專門解決焦慮症的心理咨詢師。我曾經也是個很嚴重的焦慮症患者,被各種癥狀折磨了三年多,也是在走了很多彎路後發現了治愈焦慮症的關鍵點,然後完全靠自己走出來了,沒有吃藥。 焦慮症是100%可以治愈的,但是有很多患者反覆多年不好,是因為治療的方向搞錯了。比如吃藥暫時好了,但是關鍵的認 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...