parent
a3e6e98b4e
commit
ecddbd6be3
1 changed files with 23 additions and 1 deletions
|
|
@ -41,5 +41,27 @@ class Encoder(json.JSONEncoder):
|
||||||
|
|
||||||
|
|
||||||
class JsonFormatter(IFormatter):
|
class JsonFormatter(IFormatter):
|
||||||
|
def __init__(self):
|
||||||
|
IFormatter.__init__(self)
|
||||||
|
self.queue = []
|
||||||
|
|
||||||
|
def flush(self):
|
||||||
|
if len(self.queue) == 0:
|
||||||
|
return
|
||||||
|
elif len(self.queue) == 1:
|
||||||
|
print self.queue[0]
|
||||||
|
else:
|
||||||
|
result = u""
|
||||||
|
first = False
|
||||||
|
result += u"["
|
||||||
|
for item in self.queue:
|
||||||
|
if not first:
|
||||||
|
first = True
|
||||||
|
else:
|
||||||
|
result += u","
|
||||||
|
result += item
|
||||||
|
result += "]"
|
||||||
|
print result
|
||||||
|
|
||||||
def format_dict(self, item):
|
def format_dict(self, item):
|
||||||
return json.dumps(item, cls=Encoder)
|
self.queue.append(json.dumps(item, cls=Encoder))
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue