aggregator.py 文件源码

def get_score(self, topic, words):
        request = bson.BSON.encode({
            'key': self.key,
            'user_words': words,
            'article_words': topic,
            })

        gm_job = self.gm_client.submit_job('score', str(request))
        result = bson.BSON(gm_job.result).decode()
        if result['status'] != 'ok':
            log("Scoring article failed", level=1)
            log('Description: ' + result['description'], level=1)
            return 0

        return result['score']