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 (将#修改为@)