如何解决Python RabbitMQ - KEDA 离开打开的连接
我希望开发一种使用 RPC 模式的解决方案,其中“工作人员”将在 Kubernetes 服务器(Azure Kubernetes 服务)上的 pod 中运行。
然后,我希望通过使用 KEDA 提供的自动缩放功能,根据队列长度来扩展/缩小这些 Pod。
我已经成功地运行了这个,但是我注意到当 pod 的数量减少时(当队列中的项目数量减少时)我最终有很多正在运行的连接。当我查看这些连接的客户端时,我注意到除了我的“Pika Python 客户端库/Python 3.7.11”客户端连接(当 pod 数量减少时,它似乎确实减少)我还有许多连接客户端为“https://github.com/streadway/amqp”。这似乎是 RabbitMQ 的 Go 客户端库。
我的理解是 KEDA 是用 Go 编写的,但我对这些连接所涉及的内容以及如何关闭它们以避免列表继续增长有点迷茫。
有人对我如何关闭这些连接有任何建议吗?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。