Multicorn soilgrids_fdw_json

__init__.py

from multicorn import ForeignDataWrapper
import urllib2


class SoilGridsForeignDataWrapper(ForeignDataWrapper):
    def __init__(self, options, columns):
        super(SoilGridsForeignDataWrapper, self).__init__(options, columns)


    def execute(self, quals, columns):
        row = {}
        lat_ok = False
        long_ok = False

        if quals:
            for qual in quals:
                if qual.field_name.lower() == 'latitude' and qual.operator == '=':
                    latitude = qual.value
                    lat_ok = True
                if qual.field_name.lower() == 'longitude' and qual.operator == '=':
                    longitude = qual.value
                    long_ok = True

            if lat_ok and long_ok:
                req = urllib2.Request(
                    'http://rest.soilgrids.org/query?lon={0}&lat={1}'.format(longitude, latitude))
                req.add_header('Content-Type', 'application/json;charset=UTF-8')
                resp = urllib2.urlopen(req)
                results = resp.read()

                row['longitude'] = longitude
                row['latitude'] = latitude
                row['response'] = results

                yield row