库中有 N 张表,记录数总共 2000 万条,每张表都有一个 BSM 字段,想查找库里该字段是否有重复值,打印该重复值及所在的表名和 ID 号。
环境:python2.7,32bit 。
现在的做法是:在外部定义 defaultdict(list)类型的字典,遍历所有表格的记录,每条记录的 BSM 值为 key,表名+id 值为该 key 对应的 value (列表)中的项;最后再遍历字典,查找 value 中项数大于 1 的输出。
运行后一段时间报 内存错误,请问有什么方法吗?
1
Vegetable 2020-05-16 22:39:29 +08:00
https://github.com/search?l=Python&q=bloom&type=Repositories
布隆过滤器(英语:Bloom Filter )是 1970 年由布隆提出的。它实际上是一个很长的二进制向量和一系列随机映射函数。布隆过滤器可以用于检索一个元素是否在一个集合中。它的优点是空间效率和查询时间都远远超过一般的算法,缺点是有一定的误识别率和删除困难。 |
2
felix021 2020-05-16 22:41:54 +08:00 via Android
2000 万不是大什么数据,学一点 c 吧同学。
|
3
jun0205 2020-05-16 22:44:10 +08:00
2000W 不算多,把 N 张表的 BSM 、表名,ID 放在一个视图里面,然后 SQL Group by 应该会好点
|
4
laminux29 2020-05-16 22:46:56 +08:00
不是学 C,而是要学数据结构与算法。
内存不够的情况下,用外排序就行了。 |
5
ackoly 2020-05-16 22:59:29 +08:00
SQL 处理不是更简单吗?
|
6
ackoly 2020-05-16 23:03:23 +08:00 2
-- 如果 BSM 字段长度低于 32,不用做 md5,直接使用 BSM 字段就好
-- 1. 创建汇总表 create table data_total as select 1 as flag,id,BSM,md5(BSM) as md5_value from table_a union all select 2 as flag,id,BSM,md5(BSM) as md5_value from table_b union all select 3 as flag,id,BSM,md5(BSM) as md5_value from table_c union all select 4 as flag,id,BSM,md5(BSM) as md5_value from table_d union all select 5 as flag,id,BSM,md5(BSM) as md5_value from table_e ; -- 2. 查出哪些值有重复 create table value_mult as select md5_value ,count(1) as cnt from data_total t1 group by md5_value having count(1) > 1 ; -- 3. 为 data_total 表创建索引 CREATE INDEX ix_md5_value ON data_total(md5_value); -- 4. 查询出结果 select t1.* from data_total t1 inner join value_mult t2 on t1.md5_value=t2.md5_value ; |
7
nuistzhou 2020-05-16 23:12:44 +08:00 via iPhone
不是,这玩意不是几行 SQL 就能解决的吗?为啥还要搞复杂用 python 处理呢? group by 然后 count 啥的不就 OK 了嘛?
|
8
wiix 2020-05-16 23:22:53 +08:00
如果是传统关系数据库,真就两条 sql 的事。
|
9
anaf 2020-05-16 23:55:55 +08:00
6 楼直接给了答案 看着没毛病 我还要想一下是不是这么写 说明我水平不够 6L 好 [逃]
|
10
RedisMasterNode 2020-05-17 00:00:52 +08:00
1 楼正解,BloomFilter 处理超大数据量天然优势
|
11
qbmiller 2020-05-17 00:14:01 +08:00 via iPhone
布隆过滤 ,判断重复是有误判的。2000 万 数据库 sql 就可以了。太看不起 mysql 了。如果是阿里云 rds,那更完美
|
12
qwertyegg 2020-05-17 08:40:50 +08:00
两千万小 case 了,每个记录算一个 hash 即可
|
13
xcstream 2020-05-17 10:32:23 +08:00
32bit 换成 64bit 不知道行不行,不用改代码
|