Попытка создать запрос Kinesis Analytics, чтобы предупредить, когда шаг в процессе занял слишком много времени (или умер и не продвинулся дальше). У меня есть поток данных, который содержит обновления статуса, поскольку многоэтапный процесс...

Потоковая передача в Kinesis миллиардов сообщений в день. Мы ищем реализацию, которая позволила бы нам доставлять сообщения в Kinesis с гарантией ровно один раз . Наша структура производителя требует, чтобы приемник потоковой передачи был...