Наша задача flink использует iot-данные, и мы хотели бы сохранить накопительные и некоторые события в DynamoDB.
Я ищу лучший способ получить выходные данные из моего приложения потоковой передачи flink, сохраненного в DynamoDB. Что было бы лучшим способом сделать это? Кажется, что нет раковины для этого, и я не могу найти никаких примеров. Лучше всего написать кастомную раковину? а как насчет обработки ошибок?