BinlogStreamReader creating binary key names for json objects

[Chris Lomeli]

Hi.  this is an awesome project, but I need to be able to convert rows to json, and if the mysql column is also json then I get binary key names like b'1', b'2' etc.   And json.dumps() cannot convert them.   It's easy to see where to change (parse_json_object_or_array), but it would probably break something else I don't know about.   Any advice appreciated, but I'm assuming is the way iit is for a reason and just casting these keys to str() might break something.

[Aaron Close]

I put this behind a try except around my json.dumps

def bytes_to_str(input):
if isinstance(input, bytes):
return input.decode('utf-8')
elif isinstance(input, Decimal):
return float(input)
elif isinstance(input,datetime):
return input.isoformat()
elif isinstance(input, dict):
return {bytes_to_str(key): bytes_to_str(value) for key, value in input.items()}
elif isinstance(input, list):
return [bytes_to_str(element) for element in input]
else:
return input