entity_dao.py 文件源码

def get_entity_dto(self, entity_uri):
        """Returns an EntityDAO given an entity_id
        """
        e_uuid = hashlib.md5(entity_uri.encode('utf-8')).hexdigest()

        try:
            entity = self.es.get(index=self.index, doc_type=self.type,
                                 id=e_uuid)
            return EntityDTO(entity['_source'])

        except es_exceptions.NotFoundError:
            return EntityDTO({})