python - 使用 sqlite3dbm 和 mrjob 进行地图减少

Question

我有一个 sqlite3dbm，它将数据存储在键值对中。我需要使用mrjob. 当我运行我的代码xyz.py my_db.db时，mapper fn 无法正常工作。

def mapper(k,val):
  for word in val:
     yield(word,k)

我为空k

Answer 1

检查这个。您需要适当地配置您的工作以从数据库文件中读取。