Commit caa0c6a

committed

fix tiny bugs

1 parent 166acb9 commit caa0c6aCopy full SHA for caa0c6a

File tree

+12

-3

lines changed

+12

-3

lines changed

Lines changed: 11 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,7 @@ def encode_in_py2(s):`
`25`	`25`	`import logging`
`26`	`26`	`import shlex`
`27`	`27`	`import datetime`
	`28`	`+import decimal`
`28`	`29`	`from lxml.etree import iterparse`
`29`	`30`	`from functools import reduce`
`30`	`31`	`from pymysqlreplication import BinLogStreamReader`
`@@ -177,7 +178,9 @@ def _json_serializer(self, obj):`
`177`	`178`	`"""`
`178`	`179`	`if isinstance(obj, datetime.datetime) or isinstance(obj, datetime.date):`
`179`	`180`	`return obj.isoformat()`
`180`		`- raise TypeError('Type not serializable')`
	`181`	`+ elif isinstance(obj, decimal.Decimal):`
	`182`	`+ return str(obj)`
	`183`	`+ raise TypeError('Type not serializable for obj {obj}'.format(obj=obj))`
`181`	`184`
`182`	`185`	`def _processor(self, data):`
`183`	`186`	`"""`
`@@ -225,8 +228,11 @@ def _mapper(self, data):`
`225`	`228`	`for item in data:`
`226`	`229`	`if self.mapping:`
`227`	`230`	`for k, v in self.mapping.items():`
`228`		`- item['doc'][k] = item['doc'][v]`
`229`		`- del item['doc'][v]`
	`231`	`+ try:`
	`232`	`+ item['doc'][k] = item['doc'][v]`
	`233`	`+ del item['doc'][v]`
	`234`	`+ except KeyError:`
	`235`	`+ continue`
`230`	`236`	`# print(doc)`
`231`	`237`	`yield item`
`232`	`238`
`@@ -245,6 +251,8 @@ def _formatter(self, data):`
`245`	`251`	`msg=str(e),`
`246`	`252`	`item=str(item)))`
`247`	`253`	`item['doc'][field] = None`
	`254`	`+ except TypeError as e:`
	`255`	`+ item['doc'][field] = None`
`248`	`256`	`# print(item)`
`249`	`257`	`yield item`
`250`	`258`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+__author__ = 'huangweicong'`

Comments

(0)