升级版本
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')