PythonのMapReduceの - 私はPythonでのMapReduceを実行しようとしていて、私のcsvファイルは、以下のように見えるマッパー

Question

に.CSVの最初の行をスキップ、

trip_id taxi_id pickup_time dropoff_time ... total 
0 20117 2455.0 2013-05-05 09:45:00   50.44 
1 44691 1779.0 2013-06-24 11:30:00   66.78 

と私のコードは、

import pandas as pd 
import numpy as np 
from mrjob.job import MRJob 

class MRCount(MRJob): 

def mapper(self, _, line): 
    datarow = line.replace(' ','').replace('N/A','').split(',') 
    trip_id = datarow[0] 
    total = datarow[14] 
    total = np.float(total) 
    yield ((trip_id), (total)) 

です

私のコードはマッパすべての行を渡すので、文字列ライン（インデックス）で始まるが、私は、ファイルを実行すると、それはエラーが出るので、浮いている合計でプレーをしたいので

TypeError: float() argument must be a string or a number, not 'generator' 

マッパー機能を処理するときに、csvファイルの最初の行をスキップするにはどうすればよいですか？

Answer 1

'line'の内容が正確かわかりません。あなたの問題に対する簡単な答えは、フロートを除いて試してみることです。

def mapper(self, _, line): 
    datarow = line.replace(' ','').replace('N/A','').split(',') 
    trip_id = datarow[0] 
    total = datarow[14] 
    try: 
     total = np.float(total) 
    except TypeError: 
     print("skipping line with value", datarow[14]) 
    else: 
     yield ((trip_id), (total))