Прекратить потоковую передачу, когда больше нет сообщений

Question

У меня есть конвейерное задание потокового потока данных, которое читает сообщения из заданной темы pub-sub.Я понимаю, что есть автоматическое подтверждение, когда связки совершены.Как сделать остановку конвейера там, где больше нет сообщений для потребления?

Правка - у меня есть сценарий, в котором мне нужно удалить неверные сообщения, отправленные в тему.Таким образом, это была бы разовая работа.Мое приложение отправляет сообщения по 1 мм только один раз в день (фиксированное время) на эту тему.

Answer 1

Почему вы хотите остановить потоковый конвейер, обеспокоенный тем, что начисляется плата, когда конвейер ничего не делает?Если это ваша проблема, то вам не следует беспокоиться об этом, поскольку с вас будут взимать плату только за ресурсы, которые вы используете, например, процессорное время, память, дисковое хранилище и т. Д., Пожалуйста, см. Информацию о ценах здесь

Поскольку ваш источник не ограничен (например, PubSub), вы никак не можете сказать, что в будущем больше не будет входящих данных.