jsonutil.py
239 lines
| 7.5 KiB
| text/x-python
|
PythonLexer
MinRK
|
r17133 | """Utilities to manipulate JSON objects.""" | ||
# Copyright (c) IPython Development Team. | ||||
# Distributed under the terms of the Modified BSD License. | ||||
Fernando Perez
|
r2947 | |||
MinRK
|
r8022 | import math | ||
MinRK
|
r4006 | import re | ||
Fernando Perez
|
r2947 | import types | ||
MinRK
|
r4006 | from datetime import datetime | ||
Mikhail Korobov
|
r9041 | try: | ||
# base64.encodestring is deprecated in Python 3.x | ||||
from base64 import encodebytes | ||||
except ImportError: | ||||
# Python 2.x | ||||
from base64 import encodestring as encodebytes | ||||
Thomas Kluyver
|
r4764 | from IPython.utils import py3compat | ||
Thomas Kluyver
|
r13361 | from IPython.utils.py3compat import string_types, unicode_type, iteritems | ||
Brandon Parsons
|
r6716 | from IPython.utils.encoding import DEFAULT_ENCODING | ||
Thomas Kluyver
|
r4764 | next_attr_name = '__next__' if py3compat.PY3 else 'next' | ||
MinRK
|
r4006 | #----------------------------------------------------------------------------- | ||
# Globals and constants | ||||
#----------------------------------------------------------------------------- | ||||
# timestamp formats | ||||
MinRK
|
r13511 | ISO8601 = "%Y-%m-%dT%H:%M:%S.%f" | ||
MinRK
|
r15308 | ISO8601_PAT=re.compile(r"^(\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2})(\.\d{1,6})?Z?([\+\-]\d{2}:?\d{2})?$") | ||
Fernando Perez
|
r2947 | |||
MinRK
|
r15588 | # holy crap, strptime is not threadsafe. | ||
# Calling it once at import seems to help. | ||||
datetime.strptime("1", "%d") | ||||
Fernando Perez
|
r2947 | #----------------------------------------------------------------------------- | ||
# Classes and functions | ||||
#----------------------------------------------------------------------------- | ||||
MinRK
|
r4036 | def rekey(dikt): | ||
"""Rekey a dict that has been forced to use str keys where there should be | ||||
ints by json.""" | ||||
MinRK
|
r17136 | for k in list(dikt): | ||
Thomas Kluyver
|
r13353 | if isinstance(k, string_types): | ||
MinRK
|
r17136 | nk = None | ||
MinRK
|
r4036 | try: | ||
MinRK
|
r17136 | nk = int(k) | ||
MinRK
|
r4036 | except ValueError: | ||
try: | ||||
MinRK
|
r17136 | nk = float(k) | ||
MinRK
|
r4036 | except ValueError: | ||
continue | ||||
if nk in dikt: | ||||
MinRK
|
r17136 | raise KeyError("already have key %r" % nk) | ||
MinRK
|
r4036 | dikt[nk] = dikt.pop(k) | ||
return dikt | ||||
MinRK
|
r13520 | def parse_date(s): | ||
"""parse an ISO8601 date string | ||||
If it is None or not a valid ISO8601 timestamp, | ||||
it will be returned unmodified. | ||||
Otherwise, it will return a datetime object. | ||||
""" | ||||
if s is None: | ||||
return s | ||||
m = ISO8601_PAT.match(s) | ||||
if m: | ||||
# FIXME: add actual timezone support | ||||
# this just drops the timezone info | ||||
MinRK
|
r15308 | notz, ms, tz = m.groups() | ||
if not ms: | ||||
ms = '.0' | ||||
notz = notz + ms | ||||
MinRK
|
r13520 | return datetime.strptime(notz, ISO8601) | ||
return s | ||||
MinRK
|
r4036 | |||
MinRK
|
r4006 | def extract_dates(obj): | ||
"""extract ISO8601 dates from unpacked JSON""" | ||||
if isinstance(obj, dict): | ||||
MinRK
|
r13520 | new_obj = {} # don't clobber | ||
Thomas Kluyver
|
r13361 | for k,v in iteritems(obj): | ||
MinRK
|
r13520 | new_obj[k] = extract_dates(v) | ||
obj = new_obj | ||||
MinRK
|
r4008 | elif isinstance(obj, (list, tuple)): | ||
MinRK
|
r4006 | obj = [ extract_dates(o) for o in obj ] | ||
Thomas Kluyver
|
r13353 | elif isinstance(obj, string_types): | ||
MinRK
|
r13520 | obj = parse_date(obj) | ||
MinRK
|
r4006 | return obj | ||
MinRK
|
r4008 | def squash_dates(obj): | ||
"""squash datetime objects into ISO8601 strings""" | ||||
if isinstance(obj, dict): | ||||
MinRK
|
r4010 | obj = dict(obj) # don't clobber | ||
Thomas Kluyver
|
r13361 | for k,v in iteritems(obj): | ||
MinRK
|
r4008 | obj[k] = squash_dates(v) | ||
elif isinstance(obj, (list, tuple)): | ||||
obj = [ squash_dates(o) for o in obj ] | ||||
elif isinstance(obj, datetime): | ||||
MinRK
|
r11143 | obj = obj.isoformat() | ||
MinRK
|
r4008 | return obj | ||
Mikhail Korobov
|
r9041 | |||
MinRK
|
r4006 | def date_default(obj): | ||
MinRK
|
r4008 | """default function for packing datetime objects in JSON.""" | ||
MinRK
|
r4006 | if isinstance(obj, datetime): | ||
MinRK
|
r11143 | return obj.isoformat() | ||
MinRK
|
r4006 | else: | ||
raise TypeError("%r is not JSON serializable"%obj) | ||||
MinRK
|
r7737 | # constants for identifying png/jpeg data | ||
PNG = b'\x89PNG\r\n\x1a\n' | ||||
MinRK
|
r10051 | # front of PNG base64-encoded | ||
PNG64 = b'iVBORw0KG' | ||||
MinRK
|
r7737 | JPEG = b'\xff\xd8' | ||
MinRK
|
r10051 | # front of JPEG base64-encoded | ||
JPEG64 = b'/9' | ||||
Brian E. Granger
|
r15121 | # front of PDF base64-encoded | ||
PDF64 = b'JVBER' | ||||
MinRK
|
r7737 | |||
def encode_images(format_dict): | ||||
"""b64-encodes images in a displaypub format dict | ||||
Mikhail Korobov
|
r9041 | |||
MinRK
|
r7737 | Perhaps this should be handled in json_clean itself? | ||
Mikhail Korobov
|
r9041 | |||
MinRK
|
r7746 | Parameters | ||
---------- | ||||
Mikhail Korobov
|
r9041 | |||
MinRK
|
r7746 | format_dict : dict | ||
A dictionary of display data keyed by mime-type | ||||
Mikhail Korobov
|
r9041 | |||
MinRK
|
r7746 | Returns | ||
------- | ||||
Mikhail Korobov
|
r9041 | |||
MinRK
|
r7746 | format_dict : dict | ||
A copy of the same dictionary, | ||||
Brian E. Granger
|
r15121 | but binary image data ('image/png', 'image/jpeg' or 'application/pdf') | ||
MinRK
|
r7746 | is base64-encoded. | ||
Mikhail Korobov
|
r9041 | |||
MinRK
|
r7737 | """ | ||
encoded = format_dict.copy() | ||||
MinRK
|
r10048 | |||
MinRK
|
r7737 | pngdata = format_dict.get('image/png') | ||
MinRK
|
r10048 | if isinstance(pngdata, bytes): | ||
# make sure we don't double-encode | ||||
MinRK
|
r10051 | if not pngdata.startswith(PNG64): | ||
MinRK
|
r10048 | pngdata = encodebytes(pngdata) | ||
encoded['image/png'] = pngdata.decode('ascii') | ||||
MinRK
|
r7737 | jpegdata = format_dict.get('image/jpeg') | ||
MinRK
|
r10048 | if isinstance(jpegdata, bytes): | ||
# make sure we don't double-encode | ||||
MinRK
|
r10051 | if not jpegdata.startswith(JPEG64): | ||
MinRK
|
r10048 | jpegdata = encodebytes(jpegdata) | ||
encoded['image/jpeg'] = jpegdata.decode('ascii') | ||||
Brian E. Granger
|
r15121 | pdfdata = format_dict.get('application/pdf') | ||
if isinstance(pdfdata, bytes): | ||||
# make sure we don't double-encode | ||||
if not pdfdata.startswith(PDF64): | ||||
pdfdata = encodebytes(pdfdata) | ||||
encoded['application/pdf'] = pdfdata.decode('ascii') | ||||
MinRK
|
r7737 | return encoded | ||
MinRK
|
r4006 | |||
Fernando Perez
|
r2947 | def json_clean(obj): | ||
"""Clean an object to ensure it's safe to encode in JSON. | ||||
Mikhail Korobov
|
r9041 | |||
Fernando Perez
|
r2947 | Atomic, immutable objects are returned unmodified. Sets and tuples are | ||
converted to lists, lists are copied and dicts are also copied. | ||||
Note: dicts whose keys could cause collisions upon encoding (such as a dict | ||||
with both the number 1 and the string '1' as keys) will cause a ValueError | ||||
to be raised. | ||||
Parameters | ||||
---------- | ||||
obj : any python object | ||||
Returns | ||||
------- | ||||
out : object | ||||
Mikhail Korobov
|
r9041 | |||
Fernando Perez
|
r2947 | A version of the input which will not cause an encoding error when | ||
encoded as JSON. Note that this function does not *encode* its inputs, | ||||
it simply sanitizes it so that there will be no encoding errors later. | ||||
""" | ||||
MinRK
|
r13706 | # types that are 'atomic' and ok in json as-is. | ||
atomic_ok = (unicode_type, type(None)) | ||||
Mikhail Korobov
|
r9041 | |||
Fernando Perez
|
r2947 | # containers that we need to convert into lists | ||
container_to_list = (tuple, set, types.GeneratorType) | ||||
Mikhail Korobov
|
r9041 | |||
MinRK
|
r8021 | if isinstance(obj, float): | ||
# cast out-of-range floats to their reprs | ||||
MinRK
|
r8022 | if math.isnan(obj) or math.isinf(obj): | ||
MinRK
|
r8021 | return repr(obj) | ||
MinRK
|
r13706 | return float(obj) | ||
if isinstance(obj, int): | ||||
# cast int to int, in case subclasses override __str__ (e.g. boost enum, #4598) | ||||
if isinstance(obj, bool): | ||||
# bools are ints, but we don't want to cast them to 0,1 | ||||
return obj | ||||
return int(obj) | ||||
Mikhail Korobov
|
r9041 | |||
Fernando Perez
|
r2947 | if isinstance(obj, atomic_ok): | ||
return obj | ||||
Mikhail Korobov
|
r9041 | |||
MinRK
|
r4719 | if isinstance(obj, bytes): | ||
Brandon Parsons
|
r6716 | return obj.decode(DEFAULT_ENCODING, 'replace') | ||
Mikhail Korobov
|
r9041 | |||
Fernando Perez
|
r2947 | if isinstance(obj, container_to_list) or ( | ||
Thomas Kluyver
|
r4764 | hasattr(obj, '__iter__') and hasattr(obj, next_attr_name)): | ||
Fernando Perez
|
r2947 | obj = list(obj) | ||
Mikhail Korobov
|
r9041 | |||
Fernando Perez
|
r2947 | if isinstance(obj, list): | ||
return [json_clean(x) for x in obj] | ||||
if isinstance(obj, dict): | ||||
# First, validate that the dict won't lose data in conversion due to | ||||
# key collisions after stringification. This can happen with keys like | ||||
# True and 'true' or 1 and '1', which collide in JSON. | ||||
nkeys = len(obj) | ||||
MinRK
|
r17133 | nkeys_collapsed = len(set(map(unicode_type, obj))) | ||
Fernando Perez
|
r2947 | if nkeys != nkeys_collapsed: | ||
MinRK
|
r17133 | raise ValueError('dict cannot be safely converted to JSON: ' | ||
Fernando Perez
|
r2947 | 'key collision would lead to dropped values') | ||
# If all OK, proceed by making the new dict that will be json-safe | ||||
out = {} | ||||
Thomas Kluyver
|
r13361 | for k,v in iteritems(obj): | ||
MinRK
|
r17133 | out[unicode_type(k)] = json_clean(v) | ||
Fernando Perez
|
r2947 | return out | ||
# If we get here, we don't know how to handle the object, so we just get | ||||
# its repr and return that. This will catch lambdas, open sockets, class | ||||
# objects, and any other complicated contraption that json can't encode | ||||
return repr(obj) | ||||