Моя функция отправляет полезную нагрузку на разные sftp-серверы. Эти серверы ограничены в количестве подключений, которые они могут принять.
Мне нужно решение для ограничения наших подключений к этим серверам.
Функция запускается очередями хранилища, и первый черновик проекта выглядит так:
Затем я узнал, что у вас может быть только 1 триггер для каждой функции, что привело меня к тому, что я добавил еще одну очередь агрегирования:
Я могу установить batchSize/ newBatchThreshold в исходных очередях, но я не уверен, что это сработает, потому что исходные очереди не будут знать, когда отправлять сообщения в агрегированную очередь.
- Мне нужно, чтобы функция не масштабировалась до более чем N экземпляров для всех сообщений из очереди X, поскольку sftp-сервер X не будет принимать более N подключений.
- Кроме того, мне нужна функция для масштабирования не более чем до M экземпляров для всех сообщений из очереди Y, поскольку sftp-сервер Y не будет принимать более M подключений.
Всего экземпляров будет M + N для описанного выше сценария.
Как нам настроить наш дизайн, чтобы он соответствовал этим требованиям?
