old_contents: import logging
  from pymongo import MongoClient
  
  from django.conf import settings
  
  from .untappd import UntappdApi
  
  logger = logging.getLogger(__name__)
  
  def fetch(suburb='Northcote'):
      untappd = UntappdApi(
          settings.HARVEST_UNTAPPD_CLIENT_ENDPOINT,
          client_id = settings.HARVEST_UNTAPPD_CLIENT_ID,
          client_secret = settings.HARVEST_UNTAPPD_CLIENT_SECRET
      )
  
      venues = untappd.get_venues_for_suburb(suburb)
  
      mongo_client = MongoClient(settings.MONGO_HOST, settings.MONGO_PORT)
      if not venues:
          logger.info("Could not find venues for suburb %s" % suburb)
          return None
      mongo_client.hoponit.suburbs.remove({'_id': suburb})
  
      suburb_json = {'_id': suburb}
      suburb_json['venues'] = []
      suburb_unique_beers = {}
      suburb_unique_beer_locations = {}
  
      for venue in venues:
          venue_json = venue
          checkins = untappd.get_venue_checkins(foursquare_venue_id=venue['id'])
          if not checkins:
              continue
          venue_json['checkins'] = checkins
          venue_unique_beers = {}
          for checkin in checkins:
              bid = str(checkin['beer']['bid'])
              venue_unique_beers[bid] = checkin['beer']
              suburb_unique_beers[bid] = checkin['beer']
              if not bid in  suburb_unique_beer_locations:
                  suburb_unique_beer_locations[bid] = []
              suburb_unique_beer_locations[bid].append(venue)
  
          venue_json['unique_beers'] = venue_unique_beers
          suburb_json['venues'].append(venue_json)
          suburb_json['unique_beers'] = suburb_unique_beers
          suburb_json['unique_beer_locations'] = suburb_unique_beer_locations
          venue_id = venue['id']
          mongo_client.hoponit.venues.remove({'_id': venue_id})
          mongo_client.hoponit.venues.insert({'_id': venue_id, 'venue': venue_json})
  
      mongo_client.hoponit.suburbs.insert(suburb_json)
      return suburb_json
  
  
  def fetch_task(suburb='Northcote'):
      fetch(suburb=suburb)
  
new_contents: import logging
  from pymongo import MongoClient
  
  from django.conf import settings
  
  from .untappd import UntappdApi
  
  logger = logging.getLogger(__name__)
  
  def fetch(suburb='Northcote'):
      untappd = UntappdApi(
          settings.HARVEST_UNTAPPD_CLIENT_ENDPOINT,
          client_id = settings.HARVEST_UNTAPPD_CLIENT_ID,
          client_secret = settings.HARVEST_UNTAPPD_CLIENT_SECRET
      )
  
      venues = untappd.get_venues_for_suburb(suburb)
      if not venues:
          logger.info("Could not find venues for suburb %s" % suburb)
          return None
  
      mongo_client = MongoClient(settings.MONGO_HOST, settings.MONGO_PORT)
      if not mongo_client:
          logger.info("Could not connect to Mongo client " % suburb)
          return None
      mongo_client.hoponit.suburbs.remove({'_id': suburb})
  
      suburb_json = {'_id': suburb}
      suburb_json['venues'] = []
      suburb_unique_beers = {}
      suburb_unique_beer_locations = {}
  
      for venue in venues:
          venue_json = venue
          checkins = untappd.get_venue_checkins(foursquare_venue_id=venue['id'])
          if not checkins:
              continue
          venue_json['checkins'] = checkins
          venue_unique_beers = {}
          for checkin in checkins:
              bid = str(checkin['beer']['bid'])
              venue_unique_beers[bid] = checkin['beer']
              suburb_unique_beers[bid] = checkin['beer']
              if not bid in  suburb_unique_beer_locations:
                  suburb_unique_beer_locations[bid] = []
              suburb_unique_beer_locations[bid].append(venue)
  
          venue_json['unique_beers'] = venue_unique_beers
          suburb_json['venues'].append(venue_json)
          suburb_json['unique_beers'] = suburb_unique_beers
          suburb_json['unique_beer_locations'] = suburb_unique_beer_locations
          venue_id = venue['id']
          mongo_client.hoponit.venues.remove({'_id': venue_id})
          mongo_client.hoponit.venues.insert({'_id': venue_id, 'venue': venue_json})
  
      mongo_client.hoponit.suburbs.insert(suburb_json)
      return suburb_json
  
  
  def fetch_task(suburb='Northcote'):
      fetch(suburb=suburb)
  
subject: switch back bollocks thing for MongoClient