标签:nameko

  • 如何同时使用异步模块调用nameko服务 - python

    时间:2020-9-3

    我写这样的异步程序。永久运行循环启动4事件同时发生。每个事件将运行rpc服务。在nameko服务中,我使用time.sleep(10)实现该服务。 我很困惑为什么服务每10秒完成一次。我认为服务应同时完成。如何让工作同时完成? def start_loop(loop): asyncio.set_event_loop(loop) loop.run_foreve […]

  • Nameko / RabbitMQ:OSError:服务器意外关闭连接 - python

    时间:2020-7-15

    我有两个nameko服务,它们通过RabbitMQ使用RPC进行通信。在本地使用docker-compose可以正常工作。然后,我将所有内容部署到DigitalOcean上的Kubernetes / Istio群集,并开始出现以下错误。它在10/20/60分钟内连续重复1次。服务之间的通信可以正常工作(我想在进行重构之前和之后),但是日志混乱了那些不应该发生 […]