升级版本
diff --git a/setup.py b/setup.py
index 70807a7..84a6421 100644
--- a/setup.py
+++ b/setup.py
@@ -3,7 +3,7 @@
setup(
name='python-dubbo',
- version='0.0.3-beta7',
+ version='0.0.3-beta8',
url='https://github.com/RitterHou/python-dubbo',
author='hourui',
author_email='hourui@qianmi.com',
diff --git a/tests/dubbo_test.py b/tests/dubbo_test.py
index 814c86d..0859cca 100644
--- a/tests/dubbo_test.py
+++ b/tests/dubbo_test.py
@@ -274,6 +274,32 @@
batch_spu_request = spu_query_provider.call('listByIds', spu_ids_request)
pretty_print(batch_spu_request)
+ def test_pc_es_center(self):
+ zk = ZkRegister('172.19.71.7:2181')
+ dubbo_cli = DubboClient('com.qianmi.pc.es.api.EsGoodsQueryProvider', zk_register=zk)
+
+ goods_query_request = Object('com.qianmi.pc.es.api.request.EsGoodsQueryRequest', values={
+ 'chainMasterId': 'A859315',
+ 'fromSys': 2,
+ 'pageNum': 50
+ })
+ result = dubbo_cli.call('query', goods_query_request)
+ pretty_print(result)
+
+ goods_list_by_id_request = Object('com.qianmi.pc.es.api.request.EsGoodsListByIdStringRequest', values={
+ 'chainMasterId': 'A859315',
+ 'idString': 'g51426:g51422'
+ })
+ result = dubbo_cli.call('listByIdString', goods_list_by_id_request)
+ pretty_print(result)
+
+ product_request = Object('com.qianmi.pc.es.api.request.EsGoodsListByIdStringRequest', values={
+ 'chainMasterId': 'A000000',
+ 'idString': 'NotUsed:g10529'
+ })
+ result = dubbo_cli.call('listByIdString', product_request)
+ pretty_print(result)
+
if __name__ == '__main__':
# test = TestDubbo()
diff --git a/tests/run_test.py b/tests/run_test.py
index 82e8580..1a39a80 100644
--- a/tests/run_test.py
+++ b/tests/run_test.py
@@ -12,33 +12,7 @@
def setUp(self):
init_log() # 初始化日志配置，调用端需要自己配置日志属性
- zk = ZkRegister('172.19.71.7:2181')
- self.dubbo = DubboClient('com.qianmi.pc.es.api.EsGoodsQueryProvider', zk_register=zk)
-
def test_run(self):
- # goods_query_request = Object('com.qianmi.pc.es.api.request.EsGoodsQueryRequest', values={
- # 'chainMasterId': 'A859315',
- # 'fromSys': 2,
- # 'pageNum': 50
- # })
- # result = self.dubbo.call('query', goods_query_request)
- # pretty_print(result)
- # goods_list_by_id_request = Object('com.qianmi.pc.es.api.request.EsGoodsListByIdStringRequest', values={
- # 'chainMasterId': 'A859315',
- # 'idString': 'g51426:g51422'
- # })
- # result = self.dubbo.call('listByIdString', goods_list_by_id_request)
- # pretty_print(result)
-
- # zk = ZkRegister('172.19.71.7:2181')
- # dubbo_cli = DubboClient('com.qianmi.pc.es.api.EsGoodsQueryProvider', zk_register=zk)
- # product_request = Object('com.qianmi.pc.es.api.request.EsGoodsListByIdStringRequest', values={
- # 'chainMasterId': 'A000000',
- # 'idString': 'NotUsed:g10529'
- # })
- # result = dubbo_cli.call('listByIdString', product_request)
- # pretty_print(result)
-
zk = ZkRegister('127.0.0.1:2181')
dubbo_cli = DubboClient('me.hourui.echo.provider.Echo', zk_register=zk)
for i in xrange(4):
@@ -51,7 +25,7 @@
def run(_dubbo):
- for j in xrange(100000):
+ for j in xrange(1000):
_dubbo.call('echo18')
