|
@ -27,7 +27,6 @@ redis_ = redis.Redis(connection_pool=pool, decode_responses=True) |
|
|
|
|
|
|
|
|
db_key_query = 'query' |
|
|
db_key_query = 'query' |
|
|
db_key_querying = 'querying' |
|
|
db_key_querying = 'querying' |
|
|
db_key_queryset = 'queryset' |
|
|
|
|
|
batch_size = 32 |
|
|
batch_size = 32 |
|
|
|
|
|
|
|
|
app = Flask(__name__) |
|
|
app = Flask(__name__) |
|
@ -684,7 +683,6 @@ def handle_query(): |
|
|
json.dump(d, f2, ensure_ascii=False, indent=4) |
|
|
json.dump(d, f2, ensure_ascii=False, indent=4) |
|
|
redis_.rpush(db_key_query, json.dumps({"id": id_, "path": load_request_path})) # 加入redis |
|
|
redis_.rpush(db_key_query, json.dumps({"id": id_, "path": load_request_path})) # 加入redis |
|
|
redis_.sadd(db_key_querying, id_) |
|
|
redis_.sadd(db_key_querying, id_) |
|
|
redis_.sadd(db_key_queryset, id_) |
|
|
|
|
|
return_text = {"texts": {'id': id_, }, "probabilities": None, "status_code": 200} |
|
|
return_text = {"texts": {'id': id_, }, "probabilities": None, "status_code": 200} |
|
|
print("ok") |
|
|
print("ok") |
|
|
else: |
|
|
else: |
|
|