json_conv.py 文件源码

def load_obj_json(data):
        """
        return objective json
        :param data:
        :return:
        """

        def comma_converter(data):
            """
            TO-DO :need to find a samrter way on write and read json on db and spark
            :param data:
            :return:
            """
            if(data == "") :
                data = "{}"

            if ("'" in data and "\"" in data):
                if (data.index("'") < data.index("\"")):
                    data = data.replace("'", "\"")
            elif ("'" in data and "\"" not in data):
                data = data.replace("'", "\"")
            else:
                data = data
            return data

        try :
            if(isinstance(data, (str))):
                json_data = json.loads(comma_converter(data), object_hook=JsonObject)
            elif(isinstance(data, (TextIOWrapper))):
                json_data = json.loads(data.read(), object_hook=JsonObject)
            elif(isinstance(data, (dict))):
                json_data = json.loads(data, object_hook=JsonObject)
            elif (isinstance(data, (JsonObject))):
                return data
            else:
                raise SyntaxError ("not a right json type")
            return json_data
        except Exception as e:
            raise Exception(e)