python - 延迟不同 pod 上的 python 函数调用
问题描述
我有一个部署到 Kubernetes 的软件，在这种情况下，我想在稍后的时间点调用一个函数，但我不确定我当前的 pod 是否会执行它（可能是例如，按比例缩小）。
因此，我需要一种机制的帮助，该机制使我能够在我的软件的一个 pod 上安排一个功能以供以后使用提前遇到了。
另外 - 我需要在任何给定时间点为数千个这样的调用启用它，这是一个非常快速的执行软件，使用 Twisted python 每天处理数百万个任务。但考虑到规模的扩大和缩小，我不能只是把它放在反应堆上待会儿。
几乎任何已知模块的使用，外部 redis/db 都可以。
所以 - 我需要这个社区的帮助......
提前致谢！
解决方案
您粗略地描述了任何工作队列系统，其中 Celery 是 Python 中最常见的一种。使用 RabbitMQ 作为代理，它可以轻松扩展到您向其发送的任何流量。还可以查看 Dask，但我认为 Dask 是 baaaaaad，所以我提到它只是为了完整性。