def writerow(self, row):
"""Write row."""
line = []
for s in row:
if (type(s) == dict):
line.append(json.dumps(s))
else:
line.append(unicode(s).encode("utf-8"))
self.writer.writerow(line)
# Fetch UTF-8 output from the queue ...
data = self.queue.getvalue()
data = data.decode("utf-8")
# ... and reencode it into the target encoding
data = self.encoder.encode(data)
# write to the target stream
self.stream.write(data)
# empty queue
self.queue.truncate(0)
评论列表
文章目录