このコードを変更して、senti_avg が割り切れない (0/値) 場合、reducer() がクラッシュする代わりに NULL または NONE を出力するようにするにはどうすればよいですか?
def reducer(self, bs_id, value):
avg_data = list(value)
senti_sum = sum([a[0] for a in avg_data])
word_sum = sum([a[1] for a in avg_data])
senti_avg = senti_sum/float(word_sum)
yield (bs_id, senti_avg)