temp support dns addr

mishards/connections.py

@@ -1,5 +1,6 @@
 import logging
 import threading
+import socket
 from functools import wraps
 from contextlib import contextmanager
 from milvus import Milvus

mishards/main.py

@@ -1,6 +1,9 @@
 import os, sys
 sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 
+from urllib.parse import urlparse
+import socket
+
 from mishards import (
         settings,
         db, connect_mgr,
@@ -9,7 +12,10 @@ from mishards import (
 
 def main():
     discover.start()
-    connect_mgr.register('WOSERVER', settings.WOSERVER if not settings.TESTING else settings.TESTING_WOSERVER)
+    woserver = settings.WOSERVER if not settings.TESTING else settings.TESTING_WOSERVER
+    url = urlparse(woserver)
+    connect_mgr.register('WOSERVER',
+            '{}://{}:{}'.format(url.scheme, socket.gethostbyname(url.hostname), url.port))
     server.run(port=settings.SERVER_PORT)
     return 0
 

mishards/service_handler.py

@@ -145,7 +145,7 @@ class ServiceHandler(milvus_pb2_grpc.MilvusServiceServicer):
             for res in rs:
                 res.result()
 
-        reverse = table_meta.metric_type == types.MetricType.L2
+        reverse = table_meta.metric_type == types.MetricType.IP
         return self._do_merge(all_topk_results, topk, reverse=reverse)
 
     def CreateTable(self, request, context):