数据格式如下:
······
1107 1385331000000 1.3142511607126754
1107 1385331000000 0.0021683196661660157
1107 1385331600000 0.0021683196661660157
1107 1385331600000 1.4867805985670923
1107 1385331600000 0.0021683196661660157
1107 1385332200000 1.1697626938303243
1107 1385332800000 0.0021683196661660157
1107 1385332800000 0.005813069022279304
1107 1385332800000 1.2847329440609827
1107 1385332800000 0.0021683196661660157
1107 1385333400000 1.2891586380834603
1108 1385247600000 0.026943168177151356
1108 1385247600000 6.184696475262653
1108 1385248200000 0.05946288920050806
1108 1385248200000 6.359572785335356
1108 1385248200000 0.010602880590260044
1108 1385248800000 0.026943168177151356
1108 1385248800000 5.568047923787272
1108 1385249400000 0 0.01024202685104009
1108 1385249400000 5.213017822855314
1108 1385250000000 0.01024202685104009
1108 1385250000000 5.385327254217893
1108 1385250600000 0.016259860511678353
1108 1385250600000 4.902644074658115
1108 1385251200000 4.141288808488436
1108 1385251800000 0.05388633635430271
1108 1385251800000 4.684096694966861
1108 1385251800000 0.01024202685104009
1108 1385252400000 4.386580113177049
1108 1385253000000 4.582219390797833
1108 1385253600000 5.211061096279831
1108 1385254200000 0.02048405370208018
1108 1385254200000 3.901546051563316
1108 1385254200000 0.01024202685104009
1108 1385254800000 4.0387888693118255
······
每一行数据间是tab键隔开的
第一列是标号,第二列是UTC格式时间戳,第三列是流量数据,每行的数据是10分钟内的,现在想把同一个标号的比如第一列为1107的每一小时的数据叠加起来成为新的一行(第二列的时间可以用时间戳表示或者以时间间隔表示),完全没有头绪,请大神指点指点
自己解決了,雖然可能比較複雜,但能滿足需求
如果是按照時間序列的,直接使用generator來讀取原始文件,產生新的行然後輸出就可以了.
pandas可以解決你的需求,讀取資料到dataframe再處理
這個要看你的數據量有多大了
使用 檔案句柄遍歷 不用用 readlines() (記憶體可能不夠)
使用類似字典一樣的資料結構來儲存你的訊息,如果記憶體不夠,就要再想辦法,中間訊息寫磁碟等。
大概的思路如下
你這個等於就是基於標號和小時兩個指標分組統計,用pandas讀入,用to_datetime將時間戳轉換為時間列再取小時數,然後用groupby同時對標號和小時進行分類,sum匯總就行了。
請用這個想法
https://www.zhihu.com/questio...
我覺得你這個資料格式可以稍加分析一下再做
1.第一列表示日期,你可以做為結果數組的第一層的鍵,result[date]
2.第二列看著應該是時間(分鐘)的時間戳,這樣你要求按小時來做結果,你就每個result[data]項初始化24個元素,鍵就是小時數(可以用相應的小時數的時間戳的值做鍵) ,鍵值對應的就是這個小時內的資料總和,即resultdate
3.初始化完成這個結果數組以後就簡單了,你就遍歷文件,逐行處理就可以了,每一行先讀取第一列的值,例如1107,
就操作result[1107]。接著讀取第二列,找到對應的hourtimestamp鍵,累加就行了。
4.最後遍歷result數組,輸出結果就行了。
你需要:
不到十行程式碼就可以搞定的。