python - 大文本数据合并问题思路
问题描述
背景:
我有三个csv文件,分别如下:
afile: userid, username, ....bfile: postid, userid, postname, ...cfile: postid, postnum, ...
afile = 10Gbfile = 150Gcfile = 20G
注:各个field的分隔符并不是单个字符(例如逗号),而是一串特殊符号,因为部分field可能会包含某些单字符分隔符,键盘上的单字符都试过了,都有包含,所以用了一串几个字符组成的特殊字符串来分隔,所以并不是严格的csv,这是最蛋疼的地方
目的:
我想合并这三个文件,bfile和cfile根据postid列合并,合并后再根据userid列合并afile,最终大概是postid, userid, postname, postnum, username这样的形式。
目前我的伪代码如下:
import pandas as pdchunksize = 1000000 # 100W 目前看没问题 try:resultchunktotal = []bfilereader = pd.read_csv(bfile, iterator=True, engine=’python’, sep=’##’)goon_1 = Truewhile goon_1: try:# 分块读取 bfilebfilechunk = bfilereader.get_chunk(chunksize)if not bfilechunk.empty: cfilereader = pd.read_csv(cfile, iterator=True, engine=’python’, sep=’##’) goon_2 = True while goon_2:try: # 分块读取 cfile cfilechunk = cfilereader.get_chunk(chunksize) if not cfilechunk.empty:bfilecfilechunk = pd.merge(bfilechunk, cfilechunk, on=’postid’)# 不为空代表 bfile cfile有共同的postidif not bfilecfilechunk.empty: afilereader = pd.read_csv(afile, iterator=True, engine=’python’, sep=’##’) goon_3 = True while goon_3:try: # 分块读取afile afilechunk = afilereader.get_chunk(chunksize) if not afilechunk.empty:chunkresult = pd.merge(bfilecfilechunk, afilechunk, on=’’)# 不为空表示有共同的useridif not chunkresult.empty:resultchunktotal.append(chunkresult)except StopIteration: goon_3 = Falseexcept StopIteration: goon_2 = False except StopIteration:goon_1 = Falseif len(resultchunktotal) > 0: pd.concat(resultchunktotal).to_csv(’result.csv’, index=False) except Exception as e:print(e)
但是感觉这样,很低效,所以跪求各位大神好的思路以及好的工具方法
ps: 这是一道“大数据”的伪命题,无非数据稍大了点
问题解答
回答1:别写代码啦。看起来是一行 shell 脚本的事情,用 xsv join 子命令。
相关文章:
1. macos - mac下docker如何设置代理2. 前端 - 类到底该如何去命名 .newsList 这种的命名难道真的不是过度语义化吗?~3. docker内创建jenkins访问另一个容器下的服务器问题4. javascript - if(input.type==’text’&&type != ’text’){return false;}这是什么意思?5. javascript - weex和node,js到底是怎样一个关系呢?6. docker gitlab 如何git clone?7. javascript - 求助这种功能有什么好点的插件?8. 微信开放平台 - ios APP能不能打开微信然后通过微信跳转到指定的URL?9. python - pysciter 如何配置运行环境?10. 编辑管理员信息时,为什么没有修改过的内容会为空?

网公网安备