标签:nameko
-
如何同时使用异步模块调用nameko服务 - python
我写这样的异步程序。永久运行循环启动4事件同时发生。每个事件将运行rpc服务。在nameko服务中,我使用time.sleep(10)实现该服务。 我很困惑为什么服务每10秒完成一次。我认为服务应同时完成。如何让工作同时完成? def start_loop(loop): asyncio.set_event_loop(loop) loop.run_foreve […]
-
Nameko / RabbitMQ:OSError:服务器意外关闭连接 - python
我有两个nameko服务,它们通过RabbitMQ使用RPC进行通信。在本地使用docker-compose可以正常工作。然后,我将所有内容部署到DigitalOcean上的Kubernetes / Istio群集,并开始出现以下错误。它在10/20/60分钟内连续重复1次。服务之间的通信可以正常工作(我想在进行重构之前和之后),但是日志混乱了那些不应该发生 […]