如何使用mrjob mapper reducer在Python中編寫迭代，計數器是循環中計算的一部分？

Question

我有一個程序，迭代mapper和reducer連續的n次。但是，對於每次迭代，每個鍵 - 值對的映射器都會計算出一個取決於n的值。

from mrjob.job import mrjob 

class MRWord(mrjob): 

    def mapper_init_def(self): 

     self.count = {} 


    def mapper_count(self, key, value): 

      self.count[key] = 0 

      print self.count[key] 
     # print correctly 
      yield key, value 


    def mapper_iterate(self, key, value): 
     yield key, value 
     print self.count[key] 
    #error 

    def reducer_iterate(self, key, value): 
     yield key, value 


    def steps(self): 
     return [ 
     self.mr(mapper_init=self.mapper_init_def, mapper=self.mapper_count), 

     self.mr(mapper=self.mapper_iterate, reducer=self.reducer_iterate) 
     ] 


if __name__ == '__main__': 
    MRWord.run() 

我所定義的兩步映射器減速，使得第一限定類變量，self.count。該程序產生一個錯誤，AttributeError: 'MRWord' object has no attribute 'count'。看來每個步驟都定義了一個獨立的mrjob類對象，並且該變量不能共享。有沒有另外一種方法來完成這個？

Answer 1

你爲什麼不嘗試在課堂上定義你的計數？

class MRWord(MRJob): 
    count = [] 

，丟棄

def mapper_init_def(self): 
    self.count = {}