updater.py 文件源码

def add_update_to_db(data):
    """
    log the given user opinion to the vote db collection
    """
    req_data = bson.BSON.encode({
        "key": key,
        "database": "feedlark",
        "collection": "vote",
        "data": data,
        })
    gearman_client.submit_job('db-add', str(req_data))