convert.py 文件源码

def on_post(self, req, resp):
        if req.get_param('output') == 'parquet-mr':
            json_schema = req.bounded_stream.read()

            file = tempfile.NamedTemporaryFile(delete=False, suffix='.json')
            try:
                file.write(json_schema)
                file.close()

                output = subprocess.check_output(
                    [JSONSCHEMA_PARQUET_PATH,
                     'parquet',
                     '--deref',
                     file.name],
                )
                resp.body = json.dumps({'parquet-mr': output.decode()})

            finally:
                os.remove(file.name)

        else:
            raise falcon.HTTPBadRequest(
                'Bad request', 'Invalid or missing output parameter.')