Мне нужно обновить приложение, чтобы переносить потоковые данные. Мое приложение имеет другой тип данных, которые хранятся в разных MySQL tables.
Итак, я хочу создать AWS Kinesis Firehose и AWS Lambda function для получения, преобразования и загрузите мои данные в S3 в файл CSV.
Вся найденная мною информация очень хорошо объясняет, как это реализовать, но хранит данные только в одном уникальном CSV. Я предполагаю, что имея только один уникальный CSV, он будет интерпретирован Athena как одна таблица.
Я не нашел никакой информации для создания и хранения нескольких файлов CSV с использованием Kinesis Firehose и AWS Lambda function ( который будет представлять таблицы в Афине).
Должен ли я создать новый экземпляр Kinesis Firehose для каждой таблицы, которая есть в моей базе данных MySQL? или существует какой-то способ хранить эти данные в разных файлах CSV?