|
|
@@ -12,7 +12,7 @@ ReluClient = MongoDBInterface(ReluMongodb)
|
|
|
a2s_ip = "192.168.3.240:9090"
|
|
|
topic = "quality_bid"
|
|
|
#本地测试用的主题
|
|
|
-topic_test = "test_quality_bid"
|
|
|
+# topic_test = "test_quality_bid"
|
|
|
timeout = 120
|
|
|
|
|
|
# 开始评估
|
|
|
@@ -22,7 +22,7 @@ def start_quality(data: dict, rules_id: int, a2s_ip, topic, timeout, retry=3):
|
|
|
bytes_data = json_serialize(row)
|
|
|
for t in range(retry):
|
|
|
try:
|
|
|
- resp_data = a2s_execute(a2s_ip, topic_test, timeout, bytes_data)
|
|
|
+ resp_data = a2s_execute(a2s_ip, topic, timeout, bytes_data)
|
|
|
if resp_data is None:
|
|
|
continue
|
|
|
result = json_deserialize(resp_data)
|
