

def extract_fields(self, json_dict):
    log.debug(json_dict)
    if (json_dict['request']['protocol'] != 'HTTP'):
        return None
    timestamp = json_dict['timestamp']
    url = json_dict['request']['url']
    log.debug('{0} {1}'.format(url, timestamp))
    return (url, timestamp)

dataset/ETHPy150Open Yelp/pyleus/examples/top_urls/top_urls/fields.py FieldsBolt.extract_fields/original