Sample Python class for processing NDJSON object from Import.io API

importio-ndjson.py

import os
import json
import requests

class Extractor(object):
    """ An Import.io Extractor """
    def __init__(self, guid):
        self.guid = guid

    def latest_json(self):
        """ Returns the JSON from the latest run """
        url = "https://data.import.io/extractor/{0}/json/latest".format(self.guid)
        querystring = {"_apikey": os.environ['IMPORT_IO_API_KEY']}
        headers = {"Accept": "application/x-ldjson"}
        response = requests.get(url, params=querystring, headers=headers, stream=True)
        list_resp = response.text.splitlines()
        json_resp = list(map(lambda x: json.loads(x), list_resp))
        return json_resp