json2csv.py

import unicodecsv,json
import sys

def convert2csv(data):
  fieldnames = ['user_id','name','average_stars','review_count','type'] #Filed names to filter and record, json stream

	with open('test.csv', 'wb+') as f:			
		    dict_writer = unicodecsv.DictWriter(f, fieldnames=fieldnames)
		    dict_writer.writerow(dict(zip(fieldnames, fieldnames)))
		    for line in data:
				row = json.loads(line)				
				dict_writer.writerow(row)

if __name__ == '__main__':
	inputdata = open(sys.argv[1])
	convert2csv(inputdata)