model_error.py 文件源码

def db_get(collection, query, projection):
    db_req = {
        'database': 'feedlark',
        'collection': collection,
        'query': query,
        'projection': projection
    }
    key = os.getenv('SECRETKEY')
    if key is not None:
        db_req['key'] = key
    str_bson_db_req = str(bson.BSON.encode(db_req))
    raw_db_result = gearman_client.submit_job('db-get', str_bson_db_req).result
    db_result = bson.BSON.decode(bson.BSON(raw_db_result))
    return db_result