python - map reduce に mrjob で sqlite3dbm を使用する

Question

キーと値のペアでデータを格納する sqlite3dbm があります。を使用して処理する必要がありますmrjob。コードを実行するとxyz.py my_db.db、マッパー fn が正しく動作しません。

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

私はnullを取得しますk

Answer 1

これを確認してください。データベース ファイルから読み取るには、ジョブを適切に構成する必要があります。