def _get_engine(data_dict):
 connection_url = data_dict['connection_url']
 engine = _engines.get(connection_url)
 if (not engine):
  extras = {'url': connection_url}
  engine = sqlalchemy.engine_from_config(config, 'ckan.datastore.sqlalchemy.', **extras)
  _engines[connection_url] = engine
 return engine

def _get_engine ( data_dict ) : connection_url = data_dict [ 'connection_url' ] engine = _engines . get ( connection_url ) if ( not engine ) : extras = { 'url' : connection_url } engine = sqlalchemy . engine_from_config ( config , 'ckan.datastore.sqlalchemy.' , ** extras ) _engines [ connection_url ] = engine return engine
get either read or write engine .